【问题标题】:How can I start the Flink job manager web interface when running Flink from an IDE从 IDE 运行 Flink 时如何启动 Flink 作业管理器 Web 界面
【发布时间】:2018-12-11 04:08:20
【问题描述】:

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

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

【问题讨论】:

    标签: apache-flink


    【解决方案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>
    

    以下 sn-p 将为 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);
    
    【解决方案2】:

    除了上面回答中的代码,pom文件中还需要如下依赖。

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-04-09
      • 2023-02-10
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2023-04-02
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多