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 TaskManager to the JobManager 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, long timestamp)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getTimestamp()
int	hashCode()
String	toString()

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

getCheckpointId, getJob, getTaskExecutionId

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,
                         long timestamp)

Method Detail

getTimestamp

public long getTimestamp()

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCheckpointMessage

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractCheckpointMessage

toString

public String toString()

Overrides:

toString in class AbstractCheckpointMessage