Thomas Weise created BEAM-5197:
----------------------------------
Summary: 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
{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)
