[jira] [Created] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[Shang Yuanchun (Jira)]

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)