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

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

我需要这样做，因为我想访问Flink的计数器(累加器)。

最佳答案

为了在本地启动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);