[FLINK-19914] TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available test-stability
• Assignee: Leonard Xu
• Reporter: Dian Fu
• Created: 02/Nov/20 02:14
• Updated: 12/Nov/20 15:25
• Resolved: 12/Nov/20 15:25

Description

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

[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)

Issue Links

• links to: GitHub Pull Request #14047