[FLINK-36421][fs][checkpoint] Sync outputStream before returning hand…

…le in FsCheckpointStreamFactory (#25479) Make sure the returned handle points to a file that is safely persisted to disk. Signed-off-by: Marc Aurel Fritz <[email protected]>
apache · Oct 18, 2024 · cabc6f4 · cabc6f4
1 parent fb50473
commit cabc6f4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...me/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java b/...me/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
@@ -401,6 +401,7 @@ public StreamStateHandle closeAndGetHandle() throws IOException {
                             } catch (Exception ignored) {
                             }
 
+                            sync();
                             outStream.close();
 
                             return allowRelativePaths