[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16699660#comment-16699660 ]
Kenneth Knowles commented on BEAM-5197: --------------------------------------- I'm seeing it a lot on PRs. If the test is broken and stopping work, and no culprit for rollback, I think we should {{@Ignore}} it and raise the priority of this ticket for reinstating it if it is important. > Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest > ------------------------------------------------------------------------------ > > Key: BEAM-5197 > URL: https://issues.apache.org/jira/browse/BEAM-5197 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Thomas Weise > Assignee: Maximilian Michels > Priority: Major > Fix For: 2.10.0 > > Time Spent: 0.5h > Remaining Estimate: 0h > > {code:java} > 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) > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)