org.apache.flink.runtime.messages.checkpoint

Class DeclineCheckpoint

java.lang.Object

org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage

org.apache.flink.runtime.messages.checkpoint.DeclineCheckpoint

All Implemented Interfaces:

Serializable

public class DeclineCheckpoint
extends AbstractCheckpointMessage
implements Serializable

This message is sent from the TaskExecutor to the JobMaster to tell the checkpoint coordinator that a checkpoint request could not be heeded. This can happen if a Task is already in RUNNING state but is internally not yet ready to perform checkpoints.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DeclineCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, CheckpointException checkpointException)

Method Summary

Modifier and Type	Method and Description
SerializedCheckpointException	getSerializedCheckpointException() Gets the reason why the checkpoint was declined.
String	toString()

Methods inherited from class org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage

equals, getCheckpointId, getJob, getTaskExecutionId, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

DeclineCheckpoint

public DeclineCheckpoint(JobID job,
                         ExecutionAttemptID taskExecutionId,
                         long checkpointId,
                         CheckpointException checkpointException)

Method Detail

getSerializedCheckpointException

@Nonnull
public SerializedCheckpointException getSerializedCheckpointException()

Gets the reason why the checkpoint was declined.

Returns:

The reason why the checkpoint was declined

toString

public String toString()

Overrides:

toString in class AbstractCheckpointMessage