flink之数据流图

  • Post author:
  • Post category:其他


flink之数据流图分析

StreamGraph:就是将程序的执行逻辑转换为算子之间的前后顺序(全部都是Subtask)

JobGraph: 是将部分可以合并的Subtask合并为一个Task

ExecutionGraph: 为Task赋予并行度(根据设置的并行度)

物理执行图: 将Task赋予并行度后的执行流程,落实到具体的taskmanager上,将具体的Task落实到具体的slot上

flink运行时组件

在这里插入图片描述



版权声明:本文为weixin_51473488原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。