江苏龙网

  1. 首页 > 人文 > >

在IDEA中执行Flink应用时如何访问Dashboard？

在Flink的local模式、standalone模式下 ， 我们可以访问集群中jobmanager节点默认的8081端口 ， 就可以打开Flink Dashboard界面 。
在IDEA中执行Flink应用时 ， 是否也可以显示Dashboard界面么？
可以 ， 但是需要添加flink-runtime-web 包的支持 。
下面具体介绍如何查看dashboard 。
一、添加依赖包首先 ， 需要在Flink项目的pom文件中 ， 添加如下依赖项：

org.apache.flink
flink-runtime-web_${scala.binary.version}
${flink.version}
compile

二、运行Flink应用查看web frontend端口号在IDEA中启动Flink应用 ， 查看启动日志如下：
23:05:06,130 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at localhost:43777
23:05:06,132 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender http://localhost:43777
23:05:06,136 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://localhost:43777.
23:05:06,136 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:43777 was granted leadership with leaderSessionID=fc988d7f-7780-4849-9931-fbbade84cc6f
23:05:06,136 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:43777 , session=fc988d7f-7780-4849-9931-fbbade84cc6f
23:05:06,154 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_1 .
23:05:06,173 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
23:05:06,173 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender LeaderContender: StandaloneResourceManager
23:05:06,176 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/rpc/resourcemanager_1 was granted leadership with fencing token a88541b673479191b1fb0ec4a3154cdf
23:05:06,178 INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
通过上面的日志 ， 可以看到Flink dashboard监听地址如下：
http://localhost:43777
在浏览器中访问上述URL ， 就可以访问Flink Dashboard界面了 。
在IDEA中执行Flink应用时如何访问Dashboard？文章插图
查看正在运行的running jobs：Flink Streaming Word Count by Scala ， 如图所示 。
【在IDEA中执行Flink应用时如何访问Dashboard？】其中 ， Parallelism（并行度）=8 ， 默认并行度和CPU核心数一致 。
在IDEA中执行Flink应用时如何访问Dashboard？文章插图


    推荐阅读


    上一篇：初烧入坑的福音：海贝千元级三件套小西装，让初烧晋级少花冤枉钱

    下一篇：目前唯一四边等宽的5G手机！但方向真的错了吗？