[FLINK-33958] Fix IntervalJoin restore test flakiness

- Update input data to make test output predictable
javabrett · Feb 12, 2024 · 1fbf92d · 1fbf92d
1 parent 6f4d31f
commit 1fbf92d
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/.../java/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinTestPrograms.java b/.../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"