前言

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

UI依赖项

<dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-runtime-web_2.11</artifactId>
   <version>1.12.4</version>
</dependency>

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

Configuration configuration = new Configuration();
//指定 Flink Web UI 端口为9091
configuration.setInteger("rest.port", 9091); 
StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment(configuration);
env.execute("FlinkWebUI");