[GitHub] [flink] rkhachatryan commented on a diff in pull request #20306: [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression

rkhachatryan commented on code in PR #20306: URL: https://github.com/apache/flink/pull/20306#discussion_r930864433 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java: ## @@ -168,7 +168,7 @@ private UploadTasksResult upload(Path

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20306: [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression

rkhachatryan commented on code in PR #20306: URL: https://github.com/apache/flink/pull/20306#discussion_r930161714 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java: ## @@ -168,7 +168,7 @@ private UploadTasksResult upload(Path

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20306: [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression

rkhachatryan commented on code in PR #20306: URL: https://github.com/apache/flink/pull/20306#discussion_r925596963 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java: ## @@ -168,7 +168,7 @@ private UploadTasksResult upload(Path