flink 提交任务后 Graph转换过程如下:
StreamGraph(数据流图,client解析jar包生成原始算子链,web页面执行计划图)
JobGraph(作业图,client将one-to-one且并行度相同的subtask操作链合并为一个task,提交给jobmanager)
ExecutionGraph(执行图,jobmanager根据并行度展开)
物理执行图
StreamGraph(数据流图,client解析jar包生成原始算子链,web页面执行计划图)
JobGraph(作业图,client将one-to-one且并行度相同的subtask操作链合并为一个task,提交给jobmanager)
ExecutionGraph(执行图,jobmanager根据并行度展开)
物理执行图
标签: jobmanager、并行度、graph、flink、client
笔试题
刷题
简历模板
AI算法
大数据
内推
内推: