[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681890#comment-16681890 ]
Chamikara Jayalath commented on BEAM-5197: ------------------------------------------ Another flake: https://builds.apache.org/job/beam_PreCommit_Java_Cron/565/testReport/junit/org.apache.beam.runners.flink.streaming/UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest/testWatermarkEmission_numTasks___4__numSplits_1_/ > 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: Aljoscha Krettek > Priority: Major > > {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)