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