「Flink」配置使用Flink调试WebUI

Posted 2021-03-13 ilovezihan

很多时候，我们在IDE中编写Flink代码，我们希望能够查看到Web UI，从而来了解Flink程序的运行情况。按照以下步骤操作即可，亲测有效。

1、添加Maven依赖

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

2、使用带WebUI的Flink运行环境

StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);

3、启动Flink程序

4、打开 http://localhost:8081 查看WebUI