This is an automated email from the ASF dual-hosted git repository.
shengkai 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 79e6a7e5e4c [hotfix][table-planner] Fix inconsistent test data for
temporal join (#21433)
79e6a7e5e4c is described below
commit 79e6a7e5e4c5d01f6e92f9d0cda98569a46dc6e4
Author: lincoln lee <[email protected]>
AuthorDate: Wed Dec 21 11:34:44 2022 +0800
[hotfix][table-planner] Fix inconsistent test data for temporal join
(#21433)
---
.../flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
index 5758e96f9dd..33d6224edfa 100644
---
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
+++
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TemporalJoinITCase.scala
@@ -92,7 +92,7 @@ class TemporalJoinITCase(state: StateBackendMode) extends
StreamingWithStateTest
changelogRow("+U", "Euro", "no1", 118L, "2020-08-16T00:01:00"),
changelogRow("-U", "US Dollar", "no1", 102L, "2020-08-16T00:02:00"),
changelogRow("+U", "US Dollar", "no1", 106L, "2020-08-16T00:02:00"),
- changelogRow("-D", "RMB", "no1", 708L, "2020-08-16T00:02:00")
+ changelogRow("-D", "RMB", "no1", 702L, "2020-08-16T00:02:00")
)
val rowTimeCurrencyDataUsingBeforeTime = List(
