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"
