Flink IDEA中执行的WebUI

2019年4月19日 0 条评论 3.41k 次阅读 2 人点赞

前言

Flink程序在Debug的过程中为了方便看到代码执行详细和相关指标,支持ExecutionEnvironment创建带有UI的LocalEnvironment:

但是程序在IDEA真正执行起来以后如果打开http://127.0.0.1:8081/#/overview并不能看到真正的Dashboard,以一个WordCount示例代码为例:

 

用户可以在org.apache.flink.api.java.ExecutionEnvironment#createLocalEnvironmentWithWebUI中找到封装了WebUI相关的设置信息:

继续挖掘到org.apache.flink.configuration.RestOptions发现:

默认端口为8081,但是当用户打开http://127.0.0.1:8081/#/overview,出现以前错误:

这是因为缺少了flink-web jar包,将相关依赖添加进pom.xml即可:

 

勇敢,和生活的艰难无关。

文章评论(0)