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