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

Posted to commits@flink.apache.org by dw...@apache.org on 2022/02/15 08:16:52 UTC

[flink] branch master updated (d896c93 -> 0b1ae18)

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from d896c93  [hotfix][docs] Describe how to resolve the ITCASE_USE_MINICLUSTER rule
     add fec48f3  [hotfix] Correct JUnit 5 assertions in SourceOperatorAlignmentTest
     add 0b1ae18  [FLINK-25982] Support idleness with watermark alignment

No new revisions were added by this update.

Summary of changes:
 .../connector/source/mocks/MockSourceReader.java   |   5 +
 .../SourceCoordinatorAlignmentTest.java            |  29 ++++++
 .../source/NoOpTimestampsAndWatermarks.java        |   2 +-
 .../source/ProgressiveTimestampsAndWatermarks.java |   2 +-
 .../operators/source/TimestampsAndWatermarks.java  |  13 ++-
 .../operators/source/WatermarkToDataOutput.java    |   8 +-
 .../api/operators/SourceOperatorAlignmentTest.java | 103 ++++++++++++++++++++-
 .../runtime/tasks/MultipleInputStreamTaskTest.java |   2 +-
 8 files changed, 151 insertions(+), 13 deletions(-)