Flink开发本地模式开启WebUI

2021-05-30 03:01

阅读：816

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

在开发Flink程序在本地模式调试时，需要用webUI，

首先需要导入依赖

        
        dependency>
            groupId>org.apache.flinkgroupId>
            artifactId>flink-runtime-web_2.11artifactId>
            version>${flink.version}version>
            scope>compilescope>
        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

上一篇：CSS之定位属性

下一篇：vue-html2canvas实现缩略图

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：Flink开发本地模式开启WebUI
文章链接：http://soscw.com/index.php/essay/89374.html

亲，登录后才可以留言！

Flink开发本地模式开启WebUI

评论

热门文章

推荐文章

最新文章

置顶文章