Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
FailedCheckpointStats
Statistics for a failed checkpoint.
|
Modifier and Type | Method and Description |
---|---|
PendingCheckpointStats |
CheckpointStatsTracker.getPendingCheckpointStats(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
CheckpointPlan checkpointPlan,
Collection<OperatorID> operatorCoordinatorsToConfirm,
Collection<String> masterStateIdentifiers,
CheckpointProperties props,
CompletableFuture<CompletedCheckpoint> onCompletionPromise,
PendingCheckpointStats pendingCheckpointStats,
CompletableFuture<Void> masterTriggerCompletionPromise) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.