StreamGraph是什么？ StreamGraph顾名思义是流图，它描述的是一个数据流的拓补结构，包含了创建JobGraph的所有必要信息。...

JobManager职责 JobManager的职责主要是接收Flink作业，调度Task，收集作业状态和管理TaskManager。它包含一个...

上一篇文章我们讲解了通过命令行将一个Job提交到TaskManager的整体过程，但是我们中间忽略了一些细节，比如Job提交到集群的哪些节点，J...