The original port is used so I'm changing the web port but it fails to. Can I
ask which part I made a mistake?
The error:
Exception in thread "main" java.lang.NullPointerException
at
org.apache.flink.runtime.minicluster.FlinkMiniCluster.startWebServer(FlinkMiniCluster.scala:295)
at
org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:268)
at
org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:226)
at
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:101)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1181)
The code that changing the configuration of execution environment.
Configuration env_config = new Configuration();
env_config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
env_config.setString(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, "9999");
env_config.setString(ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY,
"./data/dummyLogFile.txt");
StreamExecutionEnvironment env = new LocalStreamEnvironment(env_config);
/* Some code here
....*/
env.execute();
Flink version is 0.10.1.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-start-FlinkMiniCluster-WebServer-using-different-port-in-FlinkMiniCluster-tp4414.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
