Zakelly merged PR #25361:
URL: https://github.com/apache/flink/pull/25361
--
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.apach
Zakelly commented on code in PR #25361:
URL: https://github.com/apache/flink/pull/25361#discussion_r1771659316
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java:
##
@@ -98,39 +130,51 @@ public CompletableFuture ex
fredia commented on code in PR #25361:
URL: https://github.com/apache/flink/pull/25361#discussion_r1771339012
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java:
##
@@ -157,17 +157,27 @@ public class ForStOptions {
flinkbot commented on PR #25361:
URL: https://github.com/apache/flink/pull/25361#issuecomment-2360874824
## CI report:
* 35c8a9ef754254e2860a2d1d4d020b1ff669c779 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #25361:
URL: https://github.com/apache/flink/pull/25361
## What is the purpose of the change
This PR optimize the trigger logic of `AEC`. Including draining and timeout
trigger.
## Brief change log
## Verifying this change
Th
