[FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure

1996fanrui · 1996fanrui · commit dc2613d80b04 · 2025-09-26T17:21:16.000+02:00
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
@@ -1385,8 +1385,8 @@ private void completePendingCheckpoint(PendingCheckpoint pendingCheckpoint)
                 lastSubsumed = null;
             }
 
-            pendingCheckpoint.getCompletionFuture().complete(completedCheckpoint);
             reportCompletedCheckpoint(completedCheckpoint);
+            pendingCheckpoint.getCompletionFuture().complete(completedCheckpoint);
         } catch (Exception exception) {
             // For robustness reasons, we need catch exception and try marking the checkpoint
             // completed.

Original file line number	Diff line number	Diff line change
`@@ -1385,8 +1385,8 @@ private void completePendingCheckpoint(PendingCheckpoint pendingCheckpoint)`
`1385`	`1385`	`lastSubsumed = null;`
`1386`	`1386`	`}`
`1387`	`1387`
`1388`		`- pendingCheckpoint.getCompletionFuture().complete(completedCheckpoint);`
`1389`	`1388`	`reportCompletedCheckpoint(completedCheckpoint);`
	`1389`	`+ pendingCheckpoint.getCompletionFuture().complete(completedCheckpoint);`
`1390`	`1390`	`} catch (Exception exception) {`
`1391`	`1391`	`// For robustness reasons, we need catch exception and try marking the checkpoint`
`1392`	`1392`	`// completed.`