Data flow diagram of Flink

flink Data flow graph analysis
StreamGraph: It is to convert the execution logic of the program into the sequence between operators ( All of them are Subtask)
JobGraph: It is possible to merge parts Subtask Merge into one Task
ExecutionGraph: by Task Give parallelism ( According to the set parallelism )
Physical execution diagram : take Task The execution flow after the parallelism is given , Implement to specific taskmanager On , Will be specific Task Implement to specific slot On

flink Runtime components