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(-)