[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r930115553 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -407,8 +408,15 @@ public

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r928324559 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r928323324 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,212 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926713715 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926707252 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java: ## @@ -686,12 +688,25 @@ public CompletableFuture submitTask(

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926698315 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926698315 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926684030 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926672725 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926149940 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926126113 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926125810 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926124747 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926124747 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ChangelogTaskLocalStateStore.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r926118182 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java: ## @@ -141,6 +158,29 @@ public void storeLocalState(

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r902497128 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractTaskLocalStateStore.java: ## @@ -0,0 +1,430 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r895055680 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java: ## @@ -76,7 +74,7 @@ public interface TaskLocalStateStore { /**