Dian Fu created FLINK-19914:
-------------------------------
Summary:
TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable
Key: FLINK-19914
URL: https://issues.apache.org/jira/browse/FLINK-19914
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.12.0
Reporter: Dian Fu
Fix For: 1.12.0
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8714&view=logs&j=904e5037-64c0-5f69-f6d5-e21b89cf6484&t=39857031-7f0c-5fd5-d730-a19c5794f839
{code}
[ERROR]
testEventTimeTemporalJoinChangelogUsingBeforeTime[StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.TemporalJoinITCase)
Time elapsed: 0.225 s <<< FAILURE!
java.lang.AssertionError:
expected:<List(+I(1,Euro,12,2020-08-15T00:01,null,null), +I(2,US
Dollar,1,2020-08-15T00:02,102,2020-08-15T00:00:02),
+I(3,RMB,40,2020-08-15T00:03,702,2020-08-15T00:00:04),
+I(4,Euro,14,2020-08-16T00:04,118,2020-08-16T00:01),
+I(5,RMB,40,2020-08-16T00:03,null,null),
+I(6,RMB,40,2020-08-16T00:04,null,null), +U(2,US
Dollar,18,2020-08-16T00:03,106,2020-08-16T00:02),
-D(6,RMB,40,2020-08-16T00:04,null,null), -U(2,US
Dollar,1,2020-08-16T00:03,106,2020-08-16T00:02))> but
was:<ArrayBuffer(+I(1,Euro,12,2020-08-15T00:01,null,null), +I(2,US
Dollar,1,2020-08-15T00:02,null,null), +I(3,RMB,40,2020-08-15T00:03,null,null),
+I(4,Euro,14,2020-08-16T00:04,118,2020-08-16T00:01),
+I(5,RMB,40,2020-08-16T00:03,null,null),
+I(6,RMB,40,2020-08-16T00:04,null,null), +U(2,US
Dollar,18,2020-08-16T00:03,106,2020-08-16T00:02),
-D(6,RMB,40,2020-08-16T00:04,null,null), -U(2,US
Dollar,1,2020-08-16T00:03,106,2020-08-16T00:02))>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:118)
at org.junit.Assert.assertEquals(Assert.java:144)
at
org.apache.flink.table.planner.runtime.stream.sql.TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime(TemporalJoinITCase.scala:498)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
