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 +
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 +
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
fromA
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
fromA
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 Ap
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
fromA
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 A
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 A
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 A
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 A
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 A
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 A
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
fromA
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 CheckpointSto
14 matches
Mail list logo