Flink本地调试配置 1.本地调试配置webUI1234567<!-- pom文件添加webUI依赖 --><dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web_${scala.binary.version}</artifactId> <version>${flink.version}</version> <scope>provided</scope></dependency> 12345// 创建flink上下文的时候需要选择创建带有webUI的上下文对象Configuration configuration = new Configuration();// 设置webUI的端口号，默认为8081端口configuration.setInteger("rest.port", 9999);StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);