不过Flink IDEA中执行的webui 需要 flink-runtime-web 包的支持
pom 如下:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
启动日志如下:
2019-08-13 09:52:58,907 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment variable 'log.file' is not set.
2019-08-13 09:52:58,907 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'Key: 'web.log.path' , default: null (deprecated keys: [jobmanager.web.log.path])'.
2019-08-13 09:52:58,943 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at localhost:2841
2019-08-13 09:52:58,943 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint@652ce654 @ http://localhost:2841
2019-08-13 09:52:58,943 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://localhost:2841.
2019-08-13 09:52:58,944 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:2841 was granted leadership with leaderSessionID=5f3b1a14-3c2c-4af7-8f00-f8b715f18d16
2019-08-13 09:52:58,944 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting job dispatcher(s) for JobManger
flink webui监听地址如下: http://localhost:2841
打开对应地址:
进入job:
Metrics 也正常:
不过 logs 和 Stdout 是没有值的
如果配置了pom 还是没有webui,先检查下端口,确定没问题,可以查看下下面的链接:
https://stackoverflow.com/questions/46988499/flink-webui-when-running-from-ide
免责申明:
本文系转载,版权归原作者所有,如若侵权请联系我们进行删除!
《数据治理行业实践白皮书》下载地址:https://fs80.cn/4w2atu
《数栈V6.0产品白皮书》下载地址:https://fs80.cn/cw0iw1
想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友,浏览袋鼠云官网:https://www.dtstack.com/?src=bbs
同时,欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」,交流最新开源技术信息,群号码:30537511,项目地址:https://github.com/DTStack