Flink开发本地模式开启WebUI

在开发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!