当运行 Flink 来自 IDE 时，如何启动 Flink 作业管理器 Web 界面

Question

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

我需要这个，因为我想访问 Flink 的计数器（累加器）。

Answer 1

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

包括依赖项：

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

以下代码段将为 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

除了上述答案中的代码外，pom文件中还需要如下依赖

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

当运行 Flink 来自 IDE 时，如何启动 Flink 作业管理器 Web 界面

How can I start the Flink job manager web interface when running Flink from an IDE

apache-flink

当 运行 Flink 来自 IDE 时，如何启动 Flink 作业管理器 Web 界面

How can I start the Flink job manager web interface when running Flink from an IDE

apache-flink

当运行 Flink 来自 IDE 时，如何启动 Flink 作业管理器 Web 界面