AHeise commented on pull request #12441: URL: https://github.com/apache/flink/pull/12441#issuecomment-638137845
Okay I investigated `org.apache.flink.table.planner.runtime.stream.sql.OverWindowITCase#testRowTimeUnBoundedPartitionedRowsOver2`. The issue in general is that the watermark is not coming from the source but from `EventTimeProcessOperator`. Since, it is not storing the watermark, the first watermark after recovery will be emitted quite late after the first element have been processed. Then some late elements may be processed before that and actually be emitted even though they shouldn't (since watermark is effectively 0). Since this more related to the test setup than anything else, I'd recommend to store the last watermark in `EventTimeProcessOperator` during checkpointing and emit on recovery. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
