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 4e326af243037..6cc1c546beb33 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"