Uses of Class
org.apache.flink.runtime.checkpoint.CheckpointFailureReason
-
Packages that use CheckpointFailureReason Package Description org.apache.flink.runtime.checkpoint org.apache.flink.runtime.messages.checkpoint This package contains the messages that are sent betweenJobMaster
andTaskExecutor
to coordinate the checkpoint snapshots of the distributed dataflow. -
-
Uses of CheckpointFailureReason in org.apache.flink.runtime.checkpoint
Methods in org.apache.flink.runtime.checkpoint that return CheckpointFailureReason Modifier and Type Method Description CheckpointFailureReason
CheckpointException. getCheckpointFailureReason()
static CheckpointFailureReason
CheckpointFailureReason. valueOf(String name)
Returns the enum constant of this type with the specified name.static CheckpointFailureReason[]
CheckpointFailureReason. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.runtime.checkpoint with parameters of type CheckpointFailureReason Modifier and Type Method Description void
PendingCheckpoint. abort(CheckpointFailureReason reason, Throwable cause, CheckpointsCleaner checkpointsCleaner, Runnable postCleanup, Executor executor, CheckpointStatsTracker statsTracker)
Aborts a checkpoint with reason and cause.Constructors in org.apache.flink.runtime.checkpoint with parameters of type CheckpointFailureReason Constructor Description CheckpointException(String message, CheckpointFailureReason failureReason)
CheckpointException(String message, CheckpointFailureReason failureReason, Throwable cause)
CheckpointException(CheckpointFailureReason failureReason)
CheckpointException(CheckpointFailureReason failureReason, Throwable cause)
-
Uses of CheckpointFailureReason in org.apache.flink.runtime.messages.checkpoint
Methods in org.apache.flink.runtime.messages.checkpoint that return CheckpointFailureReason Modifier and Type Method Description CheckpointFailureReason
SerializedCheckpointException. getCheckpointFailureReason()
-