Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-08 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-07 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-07 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-06 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-05 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-05 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-05 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-05 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-05-05 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-04-30 Thread via GitHub
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

Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-04-29 Thread via GitHub
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`

[PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]

2024-04-29 Thread via GitHub
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 -