[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-16 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r710671588 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/ChangelogBackendRestoreOperation.java

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-15 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r709721022 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/ChangelogBackendRestoreOperation.java

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-15 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r709711663 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-14 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r708803812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -48,20 +49,25 @@ List

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-13 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r707877114 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -48,20 +49,25 @@ List

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-13 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r707874711 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@