wellkilo commented on PR #1172:
URL: https://github.com/apache/flink-agents/pull/1172#issuecomment-6735162346
Thanks @wenjin272 — 8ba0573 covers the points from the review:
- The drain now runs once at the end of `processElement`, after the parallel
engine's lock is released, so `waitInFlightEventsFinished` no longer
re-enters
`ParallelExecutionLock`.
- `BatchExecutionTest` covers serial and parallel execution, repeated keys
on the
batch backend, and cross-key concurrency with the regular backend;
`CompileUtilsTest` is updated accordingly.
- `runtime/API.md` and `runtime/Method.md` are removed, and the backend /
sorted-inputs tradeoff is documented in
`docs/content/docs/operations/deployment.md`.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
