[FLINK-12768] FlinkKinesisConsumerTest.testSourceSynchronization unstable on Travis

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available test-stability
• Assignee: Thomas Weise
• Reporter: Till Rohrmann
• Created: 06/Jun/19 09:38
• Updated: 02/Aug/19 17:52
• Resolved: 02/Aug/19 17:39

Description

The FlinkKinesisConsumerTest.testSourceSynchronization seems to be unstable on Travis. It fails with

[ERROR] testSourceSynchronization(org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest)  Time elapsed: 10.031 s  <<< FAILURE!
java.lang.AssertionError: 

Expected: iterable containing ["1", <Watermark @ -4>]
     but: No item matched: <Watermark @ -4>
	at org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest.testSourceSynchronization(FlinkKinesisConsumerTest.java:950)

https://api.travis-ci.org/v3/job/541845510/log.txt

While looking into the problem, I noticed that the test case takes 1 second to execute on my machine. I'm wondering whether this really needs to take this long. Moreover, the test code contains Thread.sleeps and uses Whiteboxing which we should avoid.

Issue Links

• links to: GitHub Pull Request #9136
• links to: GitHub Pull Request #9183