File tree Expand file tree Collapse file tree 2 files changed +11
-9
lines changed
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint Expand file tree Collapse file tree 2 files changed +11
-9
lines changed Original file line number Diff line number Diff line change @@ -106,7 +106,16 @@ PendingCheckpointStats reportPendingCheckpoint(
106
106
107
107
void reportFailedCheckpoint (FailedCheckpointStats failed );
108
108
109
+ /**
110
+ * Callback when a checkpoint failure without in progress checkpoint. For example, it should be
111
+ * callback when triggering checkpoint failure before creating PendingCheckpoint.
112
+ */
109
113
void reportFailedCheckpointsWithoutInProgress ();
110
114
115
+ /**
116
+ * Creates a new snapshot of the available stats.
117
+ *
118
+ * @return The latest statistics snapshot.
119
+ */
111
120
CheckpointStatsSnapshot createSnapshot ();
112
121
}
Original file line number Diff line number Diff line change @@ -111,11 +111,7 @@ public DefaultCheckpointStatsTracker(
111
111
registerMetrics (metricGroup );
112
112
}
113
113
114
- /**
115
- * Creates a new snapshot of the available stats.
116
- *
117
- * @return The latest statistics snapshot.
118
- */
114
+ @ Override
119
115
public CheckpointStatsSnapshot createSnapshot () {
120
116
CheckpointStatsSnapshot snapshot = latestSnapshot ;
121
117
@@ -253,10 +249,7 @@ private void logCheckpointStatistics(AbstractCheckpointStats checkpointStats) {
253
249
}
254
250
}
255
251
256
- /**
257
- * Callback when a checkpoint failure without in progress checkpoint. For example, it should be
258
- * callback when triggering checkpoint failure before creating PendingCheckpoint.
259
- */
252
+ @ Override
260
253
public void reportFailedCheckpointsWithoutInProgress () {
261
254
statsReadWriteLock .lock ();
262
255
try {
You can’t perform that action at this time.
0 commit comments