码迷,mamicode.com
首页 > Web开发 > 详细

Flink开发本地模式开启WebUI

时间:2021-04-24 11:56:23      阅读:0      评论:0      收藏:0      [点我收藏+]

标签: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!

Flink开发本地模式开启WebUI

标签:lin   port   depend   bind   运行   with   ati   art   link   

原文地址:https://www.cnblogs.com/yoyowin/p/14693690.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!