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

Question

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

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

Answer 1

为了在本地启动Flink时启动Web界面,我们必须启用Web界面FlinkMiniCluster.该FlinkMiniCluster是类管理当地所有弗林克服务的启动.

包括依赖:

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

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

// 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);

Answer 2

在 Flink 新版本中ConfigConstants.LOCAL_START_WEBSERVER已弃用，您可以使用以下内容，

StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());

另外不要忘记添加flink-runtime-web依赖项。

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