Flink 在IDEA执行时的webui

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

不过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

http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-access-Flink-Dashboard-at-8081-running-Flink-program-using-Eclipse-td8016.html