weiqingy commented on PR #27083: URL: https://github.com/apache/flink/pull/27083#issuecomment-4607917283
Rebased onto the latest master and resolved a conflict in `SourceOperatorStreamTaskTest`. I also aligned `MultipleInputStreamTaskTest` and `MultipleInputStreamTaskChainedSourcesCheckpointingTest` with the new behavior: `MultipleInputStreamTask` now emits `WatermarkStatus.FINISHED` on drain completion, so those tests need the extra event accounted for — filtered where it is an incidental lifecycle signal, asserted where ordering matters, and the queued-buffer counts bumped accordingly. This resolves the test failures from the earlier CI run. PTAL when you have a chance. -- 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]
