尝试使用webui运行flink时,无法从本地主机启动它

rqqzpn5f  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(554)

我正在尝试使用flinkui从intellij调试我的flink。问题是sometims没有启动抛出java.net.bindexception:无法在端口范围8081中的任何端口上启动rest端点
我应该让flink ui(从windows)运行的代码是:

String osName = System.getProperty("os.name");
  if (osName.toLowerCase().contains("win")) {
     Configuration conf = new Configuration();
     conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
     env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);
  } else {
     env = StreamExecutionEnvironment.getExecutionEnvironment();
  }

你能帮忙吗?

fzsnzjdm

fzsnzjdm1#

如果不能绑定到给定的网络端口,通常意味着它已经被占用。因此,请检查是否有任何进程在该端口上运行(旧的作业管理器?),并将其终止。
或者,您可以使用

conf.setInteger(RestOptions.PORT, 8082);

或者如果要保存,请指定一个范围

conf.setString(RestOptions.BIND_PORT, "8081-8099");

相关问题