yunfengzhou-hub commented on code in PR #25503: URL: https://github.com/apache/flink/pull/25503#discussion_r1802240575
########## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperator.java: ########## Review Comment: Seems WatermarkStatus has not been covered by the tests yet. Besides, it might be better to also verify the following in test cases: * The received order between records and non records are not changed. * All records have been drained before non record is processed. -- 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.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
