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
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
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
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
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
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
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
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
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
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
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
11 matches
Mail list logo