// 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>