public interface OperatorCoordinatorCheckpointContext extends OperatorInfo, CheckpointListener
CheckpointCoordinator
interacts with an
OperatorCoordinator
during checkpointing and checkpoint restoring.Modifier and Type | Method and Description |
---|---|
void |
abortCurrentTriggering() |
void |
checkpointCoordinator(long checkpointId,
CompletableFuture<byte[]> result) |
default void |
notifyCheckpointAborted(long checkpointId)
We override the method here to remove the checked exception.
|
void |
notifyCheckpointComplete(long checkpointId)
We override the method here to remove the checked exception.
|
void |
resetToCheckpoint(long checkpointId,
byte[] checkpointData)
Resets the coordinator to the checkpoint with the given state.
|
void |
subtaskReset(int subtask,
long checkpointId)
Called if a task is recovered as part of a partial failover, meaning a failover
handled by the scheduler's failover strategy (by default recovering a pipelined region).
|
currentParallelism, getIds, maxParallelism, operatorId
void checkpointCoordinator(long checkpointId, CompletableFuture<byte[]> result) throws Exception
Exception
void abortCurrentTriggering()
void notifyCheckpointComplete(long checkpointId)
CheckpointListener.notifyCheckpointComplete(long)
for more detail semantic of the
method.notifyCheckpointComplete
in interface CheckpointListener
checkpointId
- The ID of the checkpoint that has been completed.default void notifyCheckpointAborted(long checkpointId)
CheckpointListener.notifyCheckpointAborted(long)
for more detail semantic of the
method.notifyCheckpointAborted
in interface CheckpointListener
checkpointId
- The ID of the checkpoint that has been aborted.void resetToCheckpoint(long checkpointId, @Nullable byte[] checkpointData) throws Exception
This method is called with a null state argument in the following situations:
In both cases, the coordinator should reset to an empty (new) state.
Exception
void subtaskReset(int subtask, long checkpointId)
In contrast to this method, the resetToCheckpoint(long, byte[])
method is called
in the case of a global failover, which is the case when the coordinator (JobManager) is
recovered.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.