[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r940174368 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java: ## @@ -135,28 +148,109 @@ public void

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r940154643 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java: ## @@ -135,28 +148,109 @@ public void

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r940040701 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java: ## @@ -135,28 +148,109 @@ public void

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r940012380 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java: ## @@ -135,28 +148,109 @@ public void

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r938507104 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCache.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r938502206 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCache.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r938060565 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCache.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935341718 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageLoader.java: ## @@ -51,6 +55,9 @@ public class

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935409659 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935400344 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935386530 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935386530 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935352864 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935352864 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r935352864 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r934989507 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r932793015 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogHandleReaderWithCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930871288 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageLoader.java: ## @@ -51,6 +55,9 @@ public class

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930493192 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorWithCache.java: ## @@ -0,0 +1,367 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r928325966 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java: ## @@ -87,9 +87,14 @@ protected

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r916034348 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorWithCache.java: ## @@ -0,0 +1,367 @@ +/* + * Licensed to the Apache