public class DeclineCheckpoint extends AbstractCheckpointMessage implements Serializable
JobMasterto 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.
|Constructor and Description|
|Modifier and Type||Method and Description|
Gets the reason why the checkpoint was declined.
equals, getCheckpointId, getJob, getTaskExecutionId, hashCode
public DeclineCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, CheckpointException checkpointException)
@Nonnull public SerializedCheckpointException getSerializedCheckpointException()
public String toString()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.