Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.io.network.partition.consumer | |
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 |
---|---|
void |
IndexedInputGate.checkpointStarted(CheckpointBarrier barrier) |
void |
InputChannel.checkpointStarted(CheckpointBarrier barrier)
Called by task thread when checkpointing is started (e.g., any input channel received
barrier).
|
void |
CheckpointableInput.checkpointStarted(CheckpointBarrier barrier) |
void |
LocalInputChannel.checkpointStarted(CheckpointBarrier barrier) |
void |
RemoteInputChannel.checkpointStarted(CheckpointBarrier barrier)
Spills all queued buffers on checkpoint start.
|
void |
RecoveredInputChannel.checkpointStarted(CheckpointBarrier barrier) |
protected void |
ChannelStatePersister.startPersisting(long barrierId,
List<Buffer> knownBuffers) |
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,
boolean isUsingCustomRawKeyedState) |
Modifier and Type | Method and Description |
---|---|
void |
AlternatingController.abortPendingCheckpoint(long cancelledId,
CheckpointException exception) |
void |
UnalignedController.abortPendingCheckpoint(long cancelledId,
CheckpointException exception) |
void |
AlignedController.abortPendingCheckpoint(long cancelledId,
CheckpointException exception) |
void |
CheckpointBarrierBehaviourController.abortPendingCheckpoint(long cancelledId,
CheckpointException exception) |
protected void |
CheckpointBarrierHandler.notifyAbort(long checkpointId,
CheckpointException cause) |
Modifier and Type | Method and Description |
---|---|
boolean |
AlternatingController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
UnalignedController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
CheckpointBarrierBehaviourController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked once per checkpoint, before the first invocation of
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.