apache-flink - 从 IDE 运行 Flink 时如何启动 Flink 作业管理器 Web 界面

Question

我想从IDE本地启动时访问Flink Web界面。

我需要这个是因为我想访问 Flink 的计数器(累加器)。

Answer 1

为了在本地启动 Flink 时启动 web 界面，我们必须在 FlinkMiniCluster 中启用 web 界面。 . FlinkMiniCluster是在本地管理所有 Flink 服务启动的类。

包括依赖:

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
  <version>${flink.version}</version>
</dependency>

以下代码段将为 StreamExecutionEnvironment 启用 Web 界面:

// set up the execution environment
Configuration conf = new Configuration();
conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(8, conf);

您也可以使用 RestOptions配置服务器:

conf.setInteger(RestOptions.PORT, 8082);