flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nico Kruber (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition
Date Tue, 01 Aug 2017 09:05:00 GMT

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

Mime
View raw message