[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r820419673 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java ## @@ -72,14 +73,19 @@ public FsStateCha

[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r820652077 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java ## @@ -72,14 +73,19 @@ public FsStateCha

[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r821847901 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeUploader.java ## @@ -17,129 +17,16 @@ package org.apach

[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r822531325 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java ## @@ -96,19 +91,20 @@ public void upload(