Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between
JobMaster and TaskExecutor to coordinate the checkpoint snapshots of the
distributed dataflow. |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
CheckpointException |
PendingCheckpoint.getFailureCause() |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointCoordinator.abortPendingCheckpoints(CheckpointException exception)
Aborts all the pending checkpoints due to en exception.
|
void |
CheckpointFailureManager.checkFailureCounter(CheckpointException exception,
long checkpointId) |
void |
CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointException exception,
long checkpointId)
Handle job level checkpoint exception with a handler callback.
|
void |
CheckpointFailureManager.handleTaskLevelCheckpointException(CheckpointException exception,
long checkpointId,
ExecutionAttemptID executionAttemptID)
Handle task level checkpoint exception with a handler callback.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointCoordinator.receiveAcknowledgeMessage(AcknowledgeCheckpoint message,
String taskManagerLocationInfo)
Receives an AcknowledgeCheckpoint message and returns whether the message was associated with
a pending checkpoint.
|
Modifier and Type | Method and Description |
---|---|
CheckpointException |
SerializedCheckpointException.unwrap() |
Constructor and Description |
---|
DeclineCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
CheckpointException checkpointException) |
SerializedCheckpointException(CheckpointException checkpointException) |
Modifier and Type | Method and Description |
---|---|
OperatorSnapshotFutures |
StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator,
Optional<InternalTimeServiceManager<?>> timeServiceManager,
String operatorName,
long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions,
CheckpointStreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected void |
CheckpointBarrierHandler.abortPendingCheckpoint(long checkpointId,
CheckpointException exception) |
void |
CheckpointBarrierUnaligner.abortPendingCheckpoint(long checkpointId,
CheckpointException exception) |
void |
CheckpointBarrierAligner.abortPendingCheckpoint(long checkpointId,
CheckpointException exception) |
protected void |
CheckpointBarrierHandler.notifyAbort(long checkpointId,
CheckpointException cause) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.