[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
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

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-16 Thread GitBox
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 @@ //

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-16 Thread GitBox
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