Sxnan opened a new issue, #178: URL: https://github.com/apache/flink-agents/issues/178
### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description Currently, the ActionExecutionOperator process records asynchronously. This is problematic in event time processing, since the operator doesn't wait for the async processing of the records before the watermark to finish before emitting the watermark downstream. In other words, a watermark can surpass the events. We should have a similar watermark handling in the Flink async operator, see org.apache.flink.streaming.api.operators.async.AsyncWaitOperator#processWatermark ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
