[BEAM-5197] Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

• Type: Improvement
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Fix Version/s: 2.13.0
• Component/s: runner-flink
• Labels: flake
• Assignee: Maximilian Michels
• Reporter: Thomas Weise
• Created: 22/Aug/18 17:27
• Updated: 16/May/20 13:29
• Resolved: 06/May/19 19:53

Description

java.lang.NullPointerException
	at org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService$1.compare(TestProcessingTimeService.java:52)
	at org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService$1.compare(TestProcessingTimeService.java:49)
	at java.util.PriorityQueue.siftUpUsingComparator(PriorityQueue.java:670)
	at java.util.PriorityQueue.siftUp(PriorityQueue.java:646)
	at java.util.PriorityQueue.offer(PriorityQueue.java:345)
	at org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.registerTimer(TestProcessingTimeService.java:93)
	at org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.setNextWatermarkTimer(UnboundedSourceWrapper.java:452)
	at org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(UnboundedSourceWrapper.java:225)
	at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87)
	at org.apache.beam.runners.flink.streaming.UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest.testValueEmission(UnboundedSourceWrapperTest.java:153)
	

Issue Links

• relates to: BEAM-5337 [beam_PostCommit_Java_GradleBuild][:beam-runners-flink_2.11:test][Flake] Build times out in beam-runners-flink target
• links to: GitHub Pull Request #7106
• links to: GitHub Pull Request #7136
• links to: GitHub Pull Request #7137
• links to: GitHub Pull Request #7138
• links to: GitHub Pull Request #7140
• links to: GitHub Pull Request #7152
• links to: GitHub Pull Request #8504