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!