zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r790413135
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -162,4 +161,20 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r790413069
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -162,4 +161,20 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r790244561
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -162,4 +161,18 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r790244517
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/MetadataOutputStreamWrapper.java
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r786396516
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -162,4 +164,97 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r786368729
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -162,4 +164,97 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r785837813
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -109,13 +119,19 @@ public
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r785443599
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -44,7 +46,7 @@
//
zuston commented on a change in pull request #18157:
URL: https://github.com/apache/flink/pull/18157#discussion_r785443414
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java
##
@@ -62,7 +64,15 @@ public