[jira] [Closed] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition

["Nico Kruber (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-5673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Nico Kruber closed FLINK-5673.
------------------------------
    Resolution: Workaround

This is directly caused by the JobManager's local mode which is covered by FLINK-6487.

> NullPointerException in RemoteInputChannel.requestSubpartition
> --------------------------------------------------------------
>
>                 Key: FLINK-5673
>                 URL: https://issues.apache.org/jira/browse/FLINK-5673
>             Project: Flink
>          Issue Type: Bug
>          Components: Network
>            Reporter: Timo Walther
>
> It might be related to FLINK-5672 but I'm opening an additional issue, because it is a different exception after the second execution. The setup is identical to FLINK-5672. But if I run the job a second time I got the following exception:
> {code}
> java.lang.NullPointerException
> 	at org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:115)
> 	at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:419)
> 	at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:441)
> 	at org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:86)
> 	at org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:42)
> 	at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:73)
> 	at org.apache.flink.runtime.operators.MapDriver.run(MapDriver.java:101)
> 	at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:490)
> 	at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:355)
> 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
> 	at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)