masteryhx closed pull request #24740: [FLINK-35262] Bridge between
AsyncKeyedStateBackend and AsyncExecutionController
URL: https://github.com/apache/flink/pull/24740
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1592119008
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java:
##
@@ -114,6 +116,10 @@ public void setKeyedStateStore(@N
Zakelly commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1591946404
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java:
##
@@ -114,6 +116,10 @@ public void setKeyedStateStore(@Nul
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590495309
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -74,15 +76,20 @@ publi
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590911242
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java:
##
@@ -176,15 +180,31 @@ public StreamOperatorStat
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590908901
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590908392
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController
Zakelly commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590642587
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController im
fredia commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590611811
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController imp
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590609918
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -54,7 +59,14 @@ public class For
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590608598
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java:
##
@@ -242,6 +248,25 @@ private KeyedStateStore
checkPre
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590604525
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController
fredia commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590503035
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -104,15 +105,21 @@ public class AsyncExecutionController imp
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590495309
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -74,15 +76,20 @@ publi
jectpro7 commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1584465123
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -74,15 +76,20 @@ public
flinkbot commented on PR #24740:
URL: https://github.com/apache/flink/pull/24740#issuecomment-2082126122
## CI report:
* fd776b22665c0a416a95bcbcf0173e636434d8c1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx opened a new pull request, #24740:
URL: https://github.com/apache/flink/pull/24740
## What is the purpose of the change
Bridge between AsyncKeyedStateBackend and AsyncExecutionController, which
make aec usable with StateBackend
## Brief change log
-
17 matches
Mail list logo