[
https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-19914:
-------------------------------
Assignee: Leonard Xu
> 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
> Assignee: Leonard Xu
> Priority: Major
> Labels: test-stability
> 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)
