public class CheckpointStatsTracker extends Object
This is tightly integrated with the
CheckpointCoordinator in order to ease the
gathering of fine-grained statistics.
The tracked stats include summary counts, a detailed history of recent and in progress checkpoints as well as summaries about the size, duration and more of recent checkpoints.
Data is gathered via callbacks in the
CheckpointCoordinator and related classes like
CompletedCheckpoint, which receive the raw stats data in
the first place.
The statistics are accessed via
createSnapshot() and exposed via both the web
frontend and the
|Constructor and Description|
Creates a new checkpoint stats tracker.
|Modifier and Type||Method and Description|
Creates a new snapshot of the available stats.
Callback when a checkpoint failure without in progress checkpoint.
public CheckpointStatsTracker(int numRememberedCheckpoints, MetricGroup metricGroup)
numRememberedCheckpoints- Maximum number of checkpoints to remember, including in progress ones.
metricGroup- Metric group for exposed metrics
public CheckpointStatsSnapshot createSnapshot()
public void reportFailedCheckpointsWithoutInProgress()
public PendingCheckpointStats getPendingCheckpointStats(long checkpointId)
public void reportIncompleteStats(long checkpointId, ExecutionVertex vertex, CheckpointMetrics metrics)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.