[jira] [Created] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released

[Shang Yuanchun (Jira)]

Ufuk Celebi created FLINK-5274:
----------------------------------

             Summary: LocalInputChannel throws NPE if partition reader is released
                 Key: FLINK-5274
                 URL: https://issues.apache.org/jira/browse/FLINK-5274
             Project: Flink
          Issue Type: Bug
          Components: Network
            Reporter: Ufuk Celebi
            Assignee: Ufuk Celebi


Reported by [~rmetzger]:

{code}
java.lang.NullPointerException
       at org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.getNextBuffer(LocalInputChannel.java:185)
       at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:444)
       at org.apache.flink.streaming.runtime.io.BarrierBuffer.getNextNonBlocked(BarrierBuffer.java:152)
       at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:195)
       at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:67)
       at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:267)
       at org.apache.flink.runtime.taskmanager.Task.run(Task.java:638)
       at java.lang.Thread.run(Thread.java:745)
{code}

This is most likely caused by the result partition being released after the notifcations have happened.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)