[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575780943 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

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

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r576016613 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapValueState.java ## @@ -31,7 +31,7 @@ * @param The type of the namespa

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r577316437 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

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

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r578323771 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManagerImpl.java ## @@ -99,23 +101,30 @@ priv