// IDEA运行时,也可以看到webui,一般用于本地测试
//创建带有 web uI 的本地执行环境
Configuration config =new Configuration();
config.setBoolean("web.ui.enabled",true);
// 1. 创建Flink执行环境
final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config);
pom中添加如下依赖
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web</artifactId> <version>1.19.1</version> </dependency>