JobMaster
and TaskExecutor
to coordinate the checkpoint snapshots of the
distributed dataflow.See: Description
Class | Description |
---|---|
AbstractCheckpointMessage |
The base class of all checkpoint messages.
|
AcknowledgeCheckpoint |
This message is sent from the
TaskExecutor to the
JobMaster to signal that the checkpoint of an
individual task is completed. |
DeclineCheckpoint |
This message is sent from the
TaskExecutor to the
JobMaster to tell the checkpoint coordinator
that a checkpoint request could not be heeded. |
NotifyCheckpointComplete |
This message is sent from the
JobMaster to the
TaskExecutor to tell a task that the checkpoint
has been confirmed and that the task can commit the checkpoint to the outside world. |
TriggerCheckpoint |
This message is sent from the
JobMaster to the
TaskExecutor to tell a certain task to trigger its
checkpoint. |
JobMaster
and TaskExecutor
to coordinate the checkpoint snapshots of the
distributed dataflow.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.