欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  科技

ApacheFlink高级特性与高级应用之在webUI上分析parallelism

程序员文章站 2022-06-23 11:51:54
七、在webUI上分析parallelism 1.集群情况 3个taskManager,每个taskmanager有4个slot,共12slot,完全被占用,0个Available。...
七、在webUI上分析parallelism 1.集群情况
3个taskManager,每个taskmanager有4个slot,共12slot,完全被占用,0个Available。

ApacheFlink高级特性与高级应用之在webUI上分析parallelism

2.job使用parallelism情况
Reduce操作和DataSink操作都是12个parallelism,正好占完所有的slot.

ApacheFlink高级特性与高级应用之在webUI上分析parallelism

3.查看具体的操作执行情况
不难看出,每个机器上有4个subtask在执行,实际上就是thread。

ApacheFlink高级特性与高级应用之在webUI上分析parallelism

4.查看具体的操作调度情况
可以分析出,各个subtask在相应的机器上的调度时间。

ApacheFlink高级特性与高级应用之在webUI上分析parallelism

5.job在terminal中的执行情况
从terminal输出的日志不难看出各个操作符号的subtask的执行情况

ApacheFlink高级特性与高级应用之在webUI上分析parallelism