Blink 开源了有一段时间了,竟然没发现有人写相关的博客,其实我已经在我的知识星球里开始写了,今天来看看 Blink 为什么香?
我们先看看 Blink 黑色版本:
对比下 Flink 版本你就知道黑色版本多好看了。
你上传 jar 包的时候是这样的:
我们来看看 Blink 运行的 job 长啥样?
再来对比一下 Flink 的样子:
查看 Job Task 的详情,可以看到开始时间、接收记录、并行度、duration、Queue in/out、TPS
查看 subTask,这里可以直接点击这个日志就可以查看 task 日志:
查看背压:
查看 task metric,可以手动添加,支持的有很多,这点很重要,可以根据每个算子的监控以及时对每个算子进行调优:
查看 job 运行时间段的情况:
查看 running 的 job:
查看已经完成的 job:
查看 Task Manager:
Task Manager 分配的资源详情:
Task Manager metric 监控信息详情:
Task Manager log 文件详情,包含运行产生的日志和 GC 日志:
Task Manager 日志详情,支持高亮和分页,特别友好,妈妈再也不担心我看不见 "刷刷刷" 的日志了。
总结
介绍了 Flink 的 Blink 分支编译后运行的界面情况,总体来说很棒,期待后面 Blink 合并到 Flink!
本文原创地址是: , 未经允许禁止转载。
关注我
微信公众号:zhisheng
另外我自己整理了些 Flink 的学习资料,目前已经全部放到微信公众号了。你可以加我的微信:zhisheng_tian,然后回复关键字:Flink 即可无条件获取到。
更多私密资料请加入知识星球!
Github 代码仓库
以后这个项目的所有代码都将放在这个仓库里,包含了自己学习 flink 的一些 demo 和博客。
相关文章
1、
2、
3、
4、
5、
6、
7、
8、
9、
10、
11、
12、
13、
14、
15、
16、