[
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)
