This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch release-1.20 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 66eb9477a609a305e0e4208ffbf4151bad2d58e5 Author: Piotr Nowojski <[email protected]> AuthorDate: Mon Apr 14 11:08:36 2025 +0200 [hotfix] Fix test coverage of WatermarkAlignmentITCase Previously it has actually never tested anything as watermark alignment not been actually used. --- .../test/streaming/api/datastream/WatermarkAlignmentITCase.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkAlignmentITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkAlignmentITCase.java index e113345235e..a257a62e249 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkAlignmentITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkAlignmentITCase.java @@ -57,9 +57,14 @@ class WatermarkAlignmentITCase { (SerializableTimestampAssigner<Long>) (aLong, l) -> aLong) .withWatermarkAlignment( - "g1", Duration.ofMillis(10), Duration.ofSeconds(2)), + "g1", Duration.ofMillis(10), Duration.ofMillis(1)), "Sequence Source") - .filter((FilterFunction<Long>) aLong -> true); + .filter( + (FilterFunction<Long>) + aLong -> { + Thread.sleep(10); + return true; + }); // Execute the stream and collect the results final List<Long> result = stream.executeAndCollect(101);
