[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-09 Thread GitBox
rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r823426495 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-07 Thread GitBox
rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r820662408 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-07 Thread GitBox
rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r820618527 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-07 Thread GitBox
rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r820618527 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-07 Thread GitBox
rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r820559682 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java