Package org.apache.flink.runtime.scheduler.stopwithsavepoint

Class StopWithSavepointStoppingException

java.lang.Object

java.lang.Throwable

java.lang.Exception

org.apache.flink.util.FlinkException

org.apache.flink.runtime.scheduler.stopwithsavepoint.StopWithSavepointStoppingException

All Implemented Interfaces:

Serializable

@Experimental
public class StopWithSavepointStoppingException
extends FlinkException

Exception thrown when a savepoint has been created successfully when stopping with savepoint, but the job has not finished. In that case side-effects might have not been committed. This exception is used to communicate that to the use.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StopWithSavepointStoppingException(String savepointPath, JobID jobID)
StopWithSavepointStoppingException(String savepointPath, JobID jobID, Throwable cause)

Method Summary

Modifier and Type	Method	Description
String	getSavepointPath()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StopWithSavepointStoppingException

public StopWithSavepointStoppingException(String savepointPath,
                                          JobID jobID)

StopWithSavepointStoppingException

public StopWithSavepointStoppingException(String savepointPath,
                                          JobID jobID,
                                          Throwable cause)

Method Detail

getSavepointPath

public String getSavepointPath()