You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "weiqingy (via GitHub)" <gi...@apache.org> on 2026/06/02 23:55:21 UTC

Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink]

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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org