Timo Walther created FLINK-5673:
-----------------------------------
Summary: NullPointerException in RemoteInputChannel.requestSubpartition
Key: FLINK-5673
URL:
https://issues.apache.org/jira/browse/FLINK-5673 Project: Flink
Issue Type: Bug
Components: Core
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.3.4#6332)
Locked
