org.apache.flink.runtime.taskmanager

Interface CheckpointResponder

All Known Implementing Classes:

RpcCheckpointResponder

public interface CheckpointResponder

Responder for checkpoint acknowledge and decline messages in the Task.

Method Summary

Modifier and Type	Method and Description
void	acknowledgeCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState) Acknowledges the given checkpoint.
void	declineCheckpoint(JobID jobID, ExecutionAttemptID executionAttemptID, long checkpointId, Throwable cause) Declines the given checkpoint.

Method Detail

acknowledgeCheckpoint

void acknowledgeCheckpoint(JobID jobID,
                           ExecutionAttemptID executionAttemptID,
                           long checkpointId,
                           CheckpointMetrics checkpointMetrics,
                           TaskStateSnapshot subtaskState)

Acknowledges the given checkpoint.

Parameters:

jobID - Job ID of the running job

executionAttemptID - Execution attempt ID of the running task

checkpointId - Meta data for this checkpoint

checkpointMetrics - Metrics of this checkpoint

subtaskState - State handles for the checkpoint

declineCheckpoint

void declineCheckpoint(JobID jobID,
                       ExecutionAttemptID executionAttemptID,
                       long checkpointId,
                       Throwable cause)

Declines the given checkpoint.

Parameters:

jobID - Job ID of the running job

executionAttemptID - Execution attempt ID of the running task

checkpointId - The ID of the declined checkpoint

cause - The optional cause why the checkpoint was declined