This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 1fbf92dfc9e [FLINK-33958] Fix IntervalJoin restore test flakiness 1fbf92dfc9e is described below commit 1fbf92dfc9ee0e111d6ec740fe87fae27ef87d8b Author: bvarghese1 <bvargh...@confluent.io> AuthorDate: Thu Jan 25 11:22:22 2024 -0800 [FLINK-33958] Fix IntervalJoin restore test flakiness - Update input data to make test output predictable --- .../plan/nodes/exec/stream/IntervalJoinTestPrograms.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java index 4e326af2430..6cc1c546beb 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java @@ -47,9 +47,9 @@ public class IntervalJoinTestPrograms { }; static final Row[] SHIPMENT_AFTER_DATA = { - Row.of(7, 3, "2020-04-15 08:00:16"), - Row.of(11, 7, "2020-04-15 08:00:11"), - Row.of(13, 10, "2020-04-15 08:00:13") + Row.of(7, 3, "2020-04-15 08:00:15"), + Row.of(11, 7, "2020-04-15 08:00:16"), + Row.of(13, 10, "2020-04-15 08:00:16") }; static final String[] ORDERS_EVENT_TIME_SCHEMA = { @@ -102,8 +102,7 @@ public class IntervalJoinTestPrograms { "+I[2, 2020-04-15 08:00:02, 2020-04-15 08:00:05]", "+I[5, 2020-04-15 08:00:05, 2020-04-15 08:00:06]") .consumedAfterRestore( - "+I[7, 2020-04-15 08:00:09, 2020-04-15 08:00:11]", - "+I[10, 2020-04-15 08:00:11, 2020-04-15 08:00:13]") + "+I[10, 2020-04-15 08:00:11, 2020-04-15 08:00:16]") .build()) .runSql( "INSERT INTO sink_t SELECT\n" @@ -140,8 +139,8 @@ public class IntervalJoinTestPrograms { "+I[5, 2020-04-15 08:00:05, 2020-04-15 08:00:06]", "+I[4, 2020-04-15 08:00:04, 2020-04-15 08:00:15]") .consumedAfterRestore( - "+I[7, 2020-04-15 08:00:09, 2020-04-15 08:00:11]", - "+I[10, 2020-04-15 08:00:11, 2020-04-15 08:00:13]") + "+I[7, 2020-04-15 08:00:09, 2020-04-15 08:00:16]", + "+I[10, 2020-04-15 08:00:11, 2020-04-15 08:00:16]") .build()) .runSql( "INSERT INTO sink_t SELECT\n"