Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Method and Description |
---|---|
Map<Long,PendingCheckpoint> |
CheckpointCoordinator.getPendingCheckpoints() |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.