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
`AbstractAsyncStateStreamOperator/AbstractAsyncStateStreamOperato
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`
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 @@ public
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: issues-unsubscr...@flink.apache