You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by za...@apache.org on 2024/10/18 09:12:57 UTC
(flink) branch release-1.19 updated: [FLINK-36421][fs][checkpoint] Sync outputStream before returning handle in FsCheckpointStreamFactory (#25480)
This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.19 by this push:
new 8c1361177d4 [FLINK-36421][fs][checkpoint] Sync outputStream before returning handle in FsCheckpointStreamFactory (#25480)
8c1361177d4 is described below
commit 8c1361177d4fa1e430f0bdfb51ffa0e11ded0073
Author: Marc Aurel Fritz <Ma...@pm.me>
AuthorDate: Fri Oct 18 11:12:50 2024 +0200
[FLINK-36421][fs][checkpoint] Sync outputStream before returning handle in FsCheckpointStreamFactory (#25480)
Make sure the returned handle points to a file that is safely
persisted to disk.
Signed-off-by: Marc Aurel Fritz <ma...@pm.me>
---
.../apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
index dd687b95c88..7375874b69a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
@@ -401,6 +401,7 @@ public class FsCheckpointStreamFactory implements CheckpointStreamFactory {
} catch (Exception ignored) {
}
+ sync();
outStream.close();
return allowRelativePaths