[
https://issues.apache.org/jira/browse/FLINK-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5274.
------------------------------
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
555a687 (master), 1b472d2 (release-1.1)
> 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
> Fix For: 1.2.0, 1.1.4
>
>
> 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)
