Details
-
Improvement
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
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)
Attachments
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
- Resolved
- links to
(3 links to)