发简信
IP属地：吉林
-
Flink源码分析之StreamGraph
StreamGraph是什么？ StreamGraph顾名思义是流图，它描述的是一个数据流的拓补结构，包含了创建JobGraph的所有必要信息。...
-
Flink源码解析之Job提交(上)
启动Job 大家可能都知道通过上面这条命令，就可以在Flink集群上部署一个Job，执行你想要的功能，那么具体这个Job是怎么提交到集群的机器上...
-
Flink源码解析之JobManager接收Job
前一篇文章已经说过，JobManager的职责主要是接收Flink作业，调度Task，收集作业状态和管理TaskManager。那么本篇主要讲J...
-
Flink源码解析之JobManager启动JobManager职责 JobManager的职责主要是接收Flink作业，调度Task，收集作业状态和管理TaskManager。它包含一个...
-
Flink源码解析之Job提交(下)上一篇文章我们讲解了通过命令行将一个Job提交到TaskManager的整体过程，但是我们中间忽略了一些细节，比如Job提交到集群的哪些节点，J...