You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/17 09:21:00 UTC
[jira] [Commented] (FLINK-5775) NullReferenceException when running
job on local cluster
[ https://issues.apache.org/jira/browse/FLINK-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089534#comment-16089534 ]
Aljoscha Krettek commented on FLINK-5775:
-----------------------------------------
Please re-open if there's more information.
> NullReferenceException when running job on local cluster
> --------------------------------------------------------
>
> Key: FLINK-5775
> URL: https://issues.apache.org/jira/browse/FLINK-5775
> Project: Flink
> Issue Type: Bug
> Components: DataStream API
> Affects Versions: 1.2.0
> Reporter: Colin Breame
>
> When the job is submitted to a local Flink cluster (started using 'start-local.sh'), the exception below is produced.
> It might be worth pointing out that the job reads from a local file (using StreamExecutionEnvironment.readFile()).
> {code}
> Caused by: java.lang.NullPointerException
> at org.apache.flink.core.fs.Path.normalizePath(Path.java:258)
> at org.apache.flink.core.fs.Path.<init>(Path.java:144)
> at org.apache.flink.core.fs.local.LocalFileSystem.pathToFile(LocalFileSystem.java:138)
> at org.apache.flink.core.fs.local.LocalFileSystem.getFileStatus(LocalFileSystem.java:97)
> at org.apache.flink.core.fs.FileSystem.exists(FileSystem.java:464)
> at org.apache.flink.core.fs.SafetyNetWrapperFileSystem.exists(SafetyNetWrapperFileSystem.java:99)
> at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.run(ContinuousFileMonitoringFunction.java:191)
> at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)
> at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:55)
> at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:272)
> 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)