Re: [PR] [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController [flink]

2024-04-21 Thread via GitHub
fredia merged PR #24676: URL: https://github.com/apache/flink/pull/24676 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController [flink]

2024-04-18 Thread via GitHub
Zakelly commented on code in PR #24676: URL: https://github.com/apache/flink/pull/24676#discussion_r1571777947 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java: ## @@ -133,6 +136,20 @@

Re: [PR] [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController [flink]

2024-04-17 Thread via GitHub
flinkbot commented on PR #24676: URL: https://github.com/apache/flink/pull/24676#issuecomment-2062993344 ## CI report: * bc18939af1ffea146d6f2214d061cca4dc136ca6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController [flink]

2024-04-17 Thread via GitHub
fredia opened a new pull request, #24676: URL: https://github.com/apache/flink/pull/24676 ## What is the purpose of the change This PR implements checkpoint drain in `AsyncExecutionController`, and wires it to