[hotfix][runtime] Extracts CheckpointStatsTracker into interface

- Introduces DefaultCheckpointStatsTracker - Introduces NoOpCheckpointStatsTracker
apache · Jul 3, 2024 · 7c67d01 · 7c67d01
1 parent 91cf5d8
commit 7c67d01
Show file tree

Hide file tree

Showing 16 changed files with 786 additions and 583 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -2429,7 +2429,12 @@ private PendingCheckpointStats trackPendingCheckpointStats(
     }
 
     private void reportFinishedTasks(
-            PendingCheckpointStats pendingCheckpointStats, List<Execution> finishedTasks) {
+            @Nullable PendingCheckpointStats pendingCheckpointStats,
+            List<Execution> finishedTasks) {
+        if (pendingCheckpointStats == null) {
+            return;
+        }
+
         long now = System.currentTimeMillis();
         finishedTasks.forEach(
                 execution ->