flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From HungChang <unicorn.bana...@gmail.com>
Subject Cannot start FlinkMiniCluster.WebServer using different port in FlinkMiniCluster
Date Wed, 20 Jan 2016 16:06:50 GMT
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.

Mime
View raw message