当从IDE运行Flink时，我该如何启动Flink作业管理器Web界面？

Question

我希望在从IDE本地启动Flink时能够访问Flink Web界面。

我需要这样做是因为我想要访问Flink的计数器（累加器）。

- Robert Metzger

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

- Robert Metzger

---

http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-access-Flink-Dashboard-at-8081-running-Flink-program-using-Eclipse-td8016.html - Georg Heiler

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>

- Devas

Answer 3

除了上面回答中的代码外，pom文件中还需要以下依赖项。

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

- Debajyoti Pathak