标签:lin port depend bind 运行 with ati art link
在开发Flink程序在本地模式调试时,需要用webUI,
首先需要导入依赖
<!-- flink运行时的webUI --> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web_2.11</artifactId> <version>${flink.version}</version> <scope>compile</scope> </dependency>
然后在代码里开启,使用本地环境且启用UI
//使用非本地模式 // StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //使用本地模式并开启WebUI Configuration conf = new Configuration(); conf.setString(RestOptions.BIND_PORT,"8081-8089"); StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);
端口绑定给定一个范围,有小到大尝试使用端口,如果被占用则用下一个端口
over!
标签:lin port depend bind 运行 with ati art link
原文地址:https://www.cnblogs.com/yoyowin/p/14693690.html