NullPointerExcepcion while using StreamExecutionEnvironment.createRemoteEnvironment

[CFuentes]

Dear all,

Let me thank you in advance if you are reading this...

I'm trying to deploy a set of processes into a flink external cluster. When I use the ./bin/flink ... command line tool plus StreamExecutionEnvironment.getEnvironment(), everything works fine and my process gets executed. However, when I use StreamExecutionEnvironment to deploy the process without using flink command line tool, I get a NullPointerException:

Exception in thread "main" org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Failed to submit job 4b61db1db89d2dcd16d0b9e1f4671c16 (Flink Streaming Job)
        at org.apache.flink.client.program.Client.runBlocking(Client.java:370)
        at org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.executeRemotely(RemoteStreamEnvironment.java:214)
        at org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.execute(RemoteStreamEnvironment.java:171)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1181)
        at atos.knowledgelab.capture.analysis.stream.FlinkStreamVolumeAnalyzer.runVolumeAnalysis(FlinkStreamVolumeAnalyzer.java:175)
        at atos.knowledgelab.capture.analysis.stream.FlinkStreamVolumeAnalyzer.main(FlinkStreamVolumeAnalyzer.java:306)
Caused by: org.apache.flink.runtime.client.JobExecutionException: Failed to submit job 4b61db1db89d2dcd16d0b9e1f4671c16 (Flink Streaming Job)
        at org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$submitJob(JobManager.scala:1281)
        at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:478)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
        at org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
        at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
        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:118)
        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)
Caused by: java.lang.NullPointerException
        at org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$submitJob(JobManager.scala:1089)
        ... 23 more



I have seen that there is a similar issue poster in flink jira at:

https://issues.apache.org/jira/browse/FLINK-4756

But doesnt seem to me that no one is taking care of that. Does anybody here hava a hint on what can be going on and how to fix it?

Bests,