[FLINK-2020] Table API JoinITCase fails non-deterministically

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 0.9
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Fabian Hueske
• Created: 15/May/15 09:49
• Updated: 28/Feb/19 14:29
• Resolved: 14/Jan/16 20:25

Description

I observed the following failing test case in one of my Travis builds.

Tests run: 14, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 6.526 sec <<< FAILURE! - in org.apache.flink.api.scala.table.test.JoinITCase

testJoinWithMultipleKeys[Execution mode = CLUSTER](org.apache.flink.api.scala.table.test.JoinITCase)  Time elapsed: 0.265 sec  <<< FAILURE!

java.lang.AssertionError: Different number of lines in expected and obtained result. expected:<6> but was:<5>
	at org.junit.Assert.fail(Assert.java:88)
	at org.junit.Assert.failNotEquals(Assert.java:743)
	at org.junit.Assert.assertEquals(Assert.java:118)
	at org.junit.Assert.assertEquals(Assert.java:555)
	at org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:258)
	at org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:244)
	at org.apache.flink.api.scala.table.test.JoinITCase.after(JoinITCase.scala:49)