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

…le in FsCheckpointStreamFactory (#25481) 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 · 6a51962 · 6a51962
1 parent 5de5b27
commit 6a51962
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