[FLINK-8398] Stabilize flaky KinesisDataFetcherTests

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.4.0, 1.5.0
• Fix Version/s: 1.5.0, 1.4.1
• Component/s: Kinesis Connector, Tests
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 10/Jan/18 04:37
• Updated: 06/Feb/18 19:06
• Resolved: 06/Feb/18 19:06

Description

The unit tests in KinesisDataFetcherTest have very flaky implementations. They rely on on thread sleeps to wait for a certain operation to happen, which can easily miss and cause tests to fail.

Although there isn't any reports of consistent failures on these tests yet (as far as I am aware of), they can easily surface in the future.

Issue Links

• links to: GitHub Pull Request #5268