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

["Timo Walther (JIRA)" <ji...@apache.org>]

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)