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.handleCheckpointException(PendingCheckpoint pendingCheckpoint,
CheckpointProperties checkpointProperties,
CheckpointException exception,
ExecutionAttemptID executionAttemptID,
JobID job,
PendingCheckpointStats pendingCheckpointStats,
CheckpointStatsTracker statsTracker)
Failures on JM:
all checkpoints - go against failure counter.
|
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.
|
void |
CheckpointCoordinator.reportStats(long id,
ExecutionAttemptID attemptId,
CheckpointMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
Environment.declineCheckpoint(long checkpointId,
CheckpointException checkpointException)
Declines a checkpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
RecordWriter.abortCheckpoint(long checkpointId,
CheckpointException cause) |
void |
ResultPartitionWriter.abortCheckpoint(long checkpointId,
CheckpointException cause)
Abort the checkpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
PipelinedSubpartition.abortCheckpoint(long checkpointId,
CheckpointException cause) |
void |
SortMergeResultPartition.abortCheckpoint(long checkpointId,
CheckpointException cause) |
void |
BufferWritingResultPartition.abortCheckpoint(long checkpointId,
CheckpointException cause) |
abstract void |
ResultSubpartition.abortCheckpoint(long checkpointId,
CheckpointException cause) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteInputChannel.checkpointStarted(CheckpointBarrier barrier)
Spills all queued buffers on checkpoint start.
|
void |
CheckpointableInput.checkpointStarted(CheckpointBarrier barrier) |
void |
LocalInputChannel.checkpointStarted(CheckpointBarrier barrier) |
void |
InputChannel.checkpointStarted(CheckpointBarrier barrier)
Called by task thread when checkpointing is started (e.g., any input channel received
barrier).
|
void |
IndexedInputGate.checkpointStarted(CheckpointBarrier barrier) |
void |
RecoveredInputChannel.checkpointStarted(CheckpointBarrier barrier) |
protected void |
ChannelStatePersister.startPersisting(long barrierId,
List<Buffer> knownBuffers) |
Modifier and Type | Method and Description |
---|---|
void |
HsResultPartition.abortCheckpoint(long checkpointId,
CheckpointException cause) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointableTask.abortCheckpointOnBarrier(long checkpointId,
CheckpointException cause)
Aborts a checkpoint as the result of receiving possibly some checkpoint barriers, but at
least one
CancelCheckpointMarker . |
void |
AbstractInvokable.abortCheckpointOnBarrier(long checkpointId,
CheckpointException cause) |
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 |
---|---|
void |
RpcCheckpointResponder.declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointException checkpointException) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointResponder.declineCheckpoint(JobID jobID,
ExecutionAttemptID executionAttemptID,
long checkpointId,
CheckpointException checkpointException)
Declines the given checkpoint.
|
void |
RuntimeEnvironment.declineCheckpoint(long checkpointId,
CheckpointException checkpointException) |
Modifier and Type | Method and Description |
---|---|
void |
SavepointEnvironment.declineCheckpoint(long checkpointId,
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 |
---|---|
CompletableFuture<Void> |
SortingDataInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriterOutput.abortCheckpoint(long checkpointId,
CheckpointException cause) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
StreamTaskNetworkInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamOneInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamTaskInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId)
Prepares to spill the in-flight input buffers as checkpoint snapshot.
|
CompletableFuture<Void> |
StreamTaskSourceInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
CompletableFuture<Void> |
StreamMultipleInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
Modifier and Type | Method and Description |
---|---|
protected void |
CheckpointBarrierHandler.notifyAbort(long checkpointId,
CheckpointException cause) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
RescalingStreamTaskNetworkInput.prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
Modifier and Type | Method and Description |
---|---|
void |
OperatorChain.abortCheckpoint(long checkpointId,
CheckpointException cause) |
void |
StreamTask.abortCheckpointOnBarrier(long checkpointId,
CheckpointException cause) |
void |
MultipleInputStreamTask.abortCheckpointOnBarrier(long checkpointId,
CheckpointException cause) |
void |
SubtaskCheckpointCoordinator.abortCheckpointOnBarrier(long checkpointId,
CheckpointException cause,
OperatorChain<?,?> operatorChain) |
Modifier and Type | Method and Description |
---|---|
void |
SubtaskCheckpointCoordinator.initInputsCheckpoint(long id,
CheckpointOptions checkpointOptions)
Initialize new checkpoint.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.