[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r581644315 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@ -0,0

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578936411 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@ -0,0

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578932063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -242,6 +265,53 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578931859 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -242,6 +265,53 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578931575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegateStateBackend.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578904214 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578904214 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578903917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java ## @@ -162,14 +163,19 @@ public static