IDEA 启动本地 Flink Web UI_flink-runtime-web

背景

在本地调试时希望启动Flink Web UI 查看DAG图，watermark等信息，那么该如何做呢？

引入 Flink Web UI 的依赖

<dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
   <version>${flink.version}</version>
</dependency>
1
2
3
4
5

本文使用的 Flink 版本为1.12.0

创建带有 WebUI 的本地运行环境

Configuration configuration = new Configuration();
configuration.setString("rest.port","9091"); //指定 Flink Web UI 端口为9091
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);
/*

 业务代码

*/

env.execute("FlinkWebUITest");
1
2
3
4
5
6
7
8
9
10

进入 Flink WebUI

浏览器打开该地址：http://localhost:9091