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