[FLINK-6571] InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 1.3.0, 1.4.0, 1.5.0
• Component/s: API / DataStream, Tests
• Labels: pull-request-available test-stability
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 12/May/17 15:03
• Updated: 02/Apr/20 14:37
• Resolved: 02/Apr/20 14:37

Description

So this is a new one: i got a failing test (testNoMaxWatermarkOnAsyncStop) due to an uncatched InterruptedException.

[00:28:15] Tests run: 7, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.828 sec <<< FAILURE! - in org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest
[00:28:15] testNoMaxWatermarkOnAsyncStop(org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest)  Time elapsed: 0 sec  <<< ERROR!
[00:28:15] java.lang.InterruptedException: sleep interrupted
[00:28:15] 	at java.lang.Thread.sleep(Native Method)
[00:28:15] 	at org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest$InfiniteSource.run(StreamSourceOperatorTest.java:343)
[00:28:15] 	at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87)
[00:28:15] 	at org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest.testNoMaxWatermarkOnAsyncStop(StreamSourceOperatorTest.java:176)

Issue Links

• links to: GitHub Pull Request #5394
• links to: GitHub Pull Request #5394