IDEA 启动本地 Flink Web UI

IDEA 启动本地 Flink Web UI 背景

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

引入 Flink Web UI 的依赖

   org.apache.flink
   flink-runtime-web_${scala.binary.version}.    
   ${flink.version}

本文使用的 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");

进入 Flink WebUI

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