發(fā)簡(jiǎn)信
IP屬地：吉林
-
Flink源碼分析之StreamGraph
StreamGraph是什么篡悟？ StreamGraph顧名思義是流圖抖仅，它描述的是一個(gè)數(shù)據(jù)流的拓補(bǔ)結(jié)構(gòu)，包含了創(chuàng)建JobGraph的所有必要信息浩峡。...
-
Flink源碼解析之Job提交(上)
啟動(dòng)Job 大家可能都知道通過(guò)上面這條命令可岂，就可以在Flink集群上部署一個(gè)Job，執(zhí)行你想要的功能翰灾，那么具體這個(gè)Job是怎么提交到集群的機(jī)器上...
-
Flink源碼解析之JobManager接收J(rèn)ob
前一篇文章已經(jīng)說(shuō)過(guò)缕粹，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提交(下)上一篇文章我們講解了通過(guò)命令行將一個(gè)Job提交到TaskManager的整體過(guò)程，但是我們中間忽略了一些細(xì)節(jié)侈沪，比如Job提交到集群的哪些節(jié)點(diǎn)揭璃，J...