Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
Trace:
Exception in thread "main" java.lang.NullPointerException
at org.apache.flink.client.program.Client.<init>(Client.java:104)
at org.apache.flink.client.RemoteExecutor.executePlanWithJars(RemoteExecutor.java:86)
at org.apache.flink.client.RemoteExecutor.executePlan(RemoteExecutor.java:82)
at org.apache.flink.api.java.RemoteEnvironment.execute(RemoteEnvironment.java:70)
at Wordcount.main(Wordcount.java:23)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
The constructor is trying to set configuration parameter jobmanager.rpc.address with jobManagerAddress.getAddress().getHostAddress(), but jobManagerAddress.holder.addr is null. jobManagerAddress.holder.hostname and port holds the valid information.