很多时候,我们在IDE中编写Flink代码,我们希望能够查看到Web UI,从而来了解Flink程序的运行情况。按照以下步骤操作即可,亲测有效。 1、添加Maven依赖 <dependency> <groupId>org.apache.flink ...
不过Flink IDEA中执行的webui 需要 flink runtime web 包的支持 pom 如下: 启动日志如下: flink webui监听地址如下:http: localhost: 打开对应地址: 进入job: Metrics 也正常: 不过 logs 和 Stdout 是没有值的 如果配置了pom 还是没有webui,先检查下端口,确定没问题,可以查看下下面的链接: https: ...
2019-08-13 10:28 0 2503 推荐指数:
很多时候,我们在IDE中编写Flink代码,我们希望能够查看到Web UI,从而来了解Flink程序的运行情况。按照以下步骤操作即可,亲测有效。 1、添加Maven依赖 <dependency> <groupId>org.apache.flink ...
流处理程序生成流图 DataStream API所编写的流处理应用程序在生成作业图(JobGraph)并提交给JobManager之前,会预先生成流图(StreamGraph)。 ...
1.导入依赖 2.创建环境指定 3.Web UI 查看地址 flink webui监听地址如下: http://localhost:8081 ...
在开发Flink程序在本地模式调试时,需要用webUI, 首先需要导入依赖 然后在代码里开启,使用本地环境且启用UI 端口绑定给定一个范围,有小到大尝试使用端口,如果被占用则用下一个端口 over! ...
运行作业界面 在以下界面中,可以查看到作业的名称、作业的启动时间、作业总计运行时长、作业一共有多少个任务、当前正在运行多少个任务、以及作业的当前状态。 这里的程序:一共有17个任务,当前正在运行的是17个任务。 作业概览界面 在这个界面中,我们可以看到数据流图。这个程序中,一共有3个算子 ...
一、为什么需要ApplicationContextAware? 在某些类中我们经常需要通过ApplicationContext来获取需要的bean,但每一次使用new ClassPathXmlA ...
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容:所有原创文章分类汇总及配套源码,涉及Java、Docker、Kubernetes、DevOPS等; IDEA是常用的IDE,我们编写的flink任务代码如果能直接在IDEA运行,会给学习 ...