發(fā)簡信
IP屬地：吉林
-
Flink源碼分析之StreamGraph
StreamGraph是什么？ StreamGraph顧名思義是流圖，它描述的是一個數(shù)據(jù)流的拓補結構，包含了創(chuàng)建JobGraph的所有必要信息。...
-
Flink源碼解析之Job提交(上)
啟動Job 大家可能都知道通過上面這條命令，就可以在Flink集群上部署一個Job，執(zhí)行你想要的功能，那么具體這個Job是怎么提交到集群的機器上...
-
Flink源碼解析之JobManager接收Job
前一篇文章已經說過，JobManager的職責主要是接收Flink作業(yè)，調度Task，收集作業(yè)狀態(tài)和管理TaskManager。那么本篇主要講J...
-
Flink源碼解析之JobManager啟動JobManager職責 JobManager的職責主要是接收Flink作業(yè)，調度Task，收集作業(yè)狀態(tài)和管理TaskManager。它包含一個...
-
Flink源碼解析之Job提交(下)上一篇文章我們講解了通過命令行將一個Job提交到TaskManager的整體過程，但是我們中間忽略了一些細節(jié)，比如Job提交到集群的哪些節(jié)點，J...