[
https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruwen Moos resolved FLINK-4756.
-------------------------------
Resolution: Not A Bug
Version of flink for the cluster and in the maven project were to far apart.
If you have this error check the flink version used for building and of the
cluster.
> NullPointerException on submiting a job with
> StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster
> ------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-4756
> URL: https://issues.apache.org/jira/browse/FLINK-4756
> Project: Flink
> Issue Type: Bug
> Components: Cluster Management
> Affects Versions: 1.1.2
> Environment: cluster@centOS7 in a docker container
> Reporter: Ruwen Moos
>
> Flink cluster throws the following exception when I try to send my job to my
> Flink cluster with StreamExecutionEnvironment.createRemoteEnvironment.
> 2016-10-04 07:29:46,106 ERROR org.apache.flink.runtime.jobmanager.JobManager
> - Failed to submit job 08f41104b8b523380fbc8f0d7d1da6f1 (Flink
> Java Job at Tue Oct 04 09:29:37 CEST 2016)
> java.lang.NullPointerException
> at
> org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$submitJob(JobManager.scala:1089)
> at
> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:478)
> at
> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
> at
> org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
> at
> scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
> at
> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
> at
> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
> at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
> at
> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
> at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> at
> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:121)
> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
> at akka.actor.ActorCell.invoke(ActorCell.scala:487)
> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
> at akka.dispatch.Mailbox.run(Mailbox.scala:221)
> at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> The Flink programm runs as a standalone flink programm with
> StreamExecutionEnvironment.getExecutionEnvironment() without any issues. With
> getExecutionEnvironment() uploading via the web gui works when running it on
> the cluster, just not via a RemoteStreamEnvironment
> Same exception also happens when using a local cluster on windows.
> I also tried running the wordcount example from flink-examples on the
> cluster, same result.
> Jars for the job are created with the maven-assembly-plugin.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
