Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.streaming.runtime.io |
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.
|
PendingCheckpoint |
CheckpointCoordinator.triggerCheckpoint(long timestamp,
CheckpointProperties props,
String externalSavepointLocation,
boolean isPeriodic,
boolean advanceToEndOfTime) |
Modifier and Type | Method and Description |
---|---|
protected void |
CheckpointBarrierHandler.notifyAbort(long checkpointId,
CheckpointException cause) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.