Package | Description |
---|---|
org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between
JobManager
and TaskManager to coordinate the checkpoint snapshots of the
distributed dataflow. |
Modifier and Type | Class and Description |
---|---|
class |
AcknowledgeCheckpoint
This message is sent from the
TaskManager to the
JobManager to signal that the checkpoint of an
individual task is completed. |
class |
DeclineCheckpoint
This message is sent from the
TaskManager to the
JobManager to tell the checkpoint coordinator
that a checkpoint request could not be heeded. |
class |
NotifyCheckpointComplete
This message is sent from the
JobManager to the
TaskManager to tell a task that the checkpoint
has been confirmed and that the task can commit the checkpoint to the outside world. |
class |
TriggerCheckpoint
This message is sent from the
JobManager to the
TaskManager to tell a certain task to trigger its
checkpoint. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.