Flink任務(wù)提交流程

Flink任務(wù)提交流程
  • 當(dāng)一個(gè)應(yīng)用被提交時(shí)澜沟,Dispatcher分發(fā)器就會(huì)啟動(dòng)并將應(yīng)用移交給一個(gè)JobManager灾票。

  • JobManager控制一個(gè)應(yīng)用程序執(zhí)行的主進(jìn)程,每個(gè)應(yīng)用程序都會(huì)被一個(gè)不同的JobManager所控制茫虽;JobManager先接收到要執(zhí)行的應(yīng)用程序(包括作業(yè)圖JobGraph刊苍、邏輯數(shù)據(jù)流圖Logical dataflow gragh既们、打包的所有的類、庫和其他資源的jar包班缰;JobManager會(huì)將JobGraph轉(zhuǎn)換為一個(gè)物理層面的數(shù)據(jù)流圖(執(zhí)行圖:ExecutionGragh)贤壁,包含了所有可以并發(fā)執(zhí)行的任務(wù)悼枢; JobManager會(huì)向資源管理器(ResourceManager)請(qǐng)求執(zhí)行任務(wù)必要的資源埠忘,即TaskManager上的插槽(Slot),一旦獲取到足夠的資源馒索,就會(huì)將執(zhí)行圖分發(fā)到真正運(yùn)行它們的TaskManager上莹妒;在運(yùn)行過程中,JobManager會(huì)負(fù)責(zé)所有需要中央?yún)f(xié)調(diào)的操作绰上,比如檢查點(diǎn)(checkpoints)的協(xié)調(diào)旨怠。

  • ResourceManager主要負(fù)責(zé)管理任務(wù)管理器(TaskManager)的插槽(slot),Slot時(shí)Flink定義的處理資源單元蜈块;ResourceManager將有空閑插槽的TaskManager分配給JobManager鉴腻。如果ResourceManager沒有足夠的插槽來滿足JobManager的請(qǐng)求,它可以向資源提供平臺(tái)發(fā)起會(huì)話百揭,以提供啟動(dòng)TaskManager進(jìn)程的容器爽哎。

  • TaskManager一般在Flink的工作進(jìn)程中會(huì)有多個(gè),每個(gè)TaskManager都包含一定數(shù)量的插槽slots器一,插槽的數(shù)量限制了TaskManager能夠執(zhí)行的任務(wù)數(shù)量课锌。
    TaskManager啟動(dòng)之后,TaskManager會(huì)向ResoureManger注冊(cè)它的插槽祈秕,收到ResourceManger的指令后渺贤,TaskManager就會(huì)將一個(gè)或多個(gè)插槽提供個(gè)JobManager調(diào)用,JobManager就可以向插槽分配任務(wù)(tasks)來執(zhí)行请毛。
    在執(zhí)行過程中志鞍,一個(gè)TaskManager可以跟其他運(yùn)行同一應(yīng)用程序的TaskManager交換數(shù)據(jù)。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末方仿,一起剝皮案震驚了整個(gè)濱河市述雾,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌兼丰,老刑警劉巖玻孟,帶你破解...
    沈念sama閱讀 217,826評(píng)論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異鳍征,居然都是意外死亡黍翎,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,968評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門艳丛,熙熙樓的掌柜王于貴愁眉苦臉地迎上來匣掸,“玉大人趟紊,你說我怎么就攤上這事∨鲈停” “怎么了霎匈?”我有些...
    開封第一講書人閱讀 164,234評(píng)論 0 354
  • 文/不壞的土叔 我叫張陵,是天一觀的道長送爸。 經(jīng)常有香客問我铛嘱,道長,這世上最難降的妖魔是什么袭厂? 我笑而不...
    開封第一講書人閱讀 58,562評(píng)論 1 293
  • 正文 為了忘掉前任墨吓,我火速辦了婚禮,結(jié)果婚禮上纹磺,老公的妹妹穿的比我還像新娘帖烘。我一直安慰自己,他們只是感情好橄杨,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,611評(píng)論 6 392
  • 文/花漫 我一把揭開白布秘症。 她就那樣靜靜地躺著,像睡著了一般式矫。 火紅的嫁衣襯著肌膚如雪乡摹。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,482評(píng)論 1 302
  • 那天衷佃,我揣著相機(jī)與錄音趟卸,去河邊找鬼。 笑死氏义,一個(gè)胖子當(dāng)著我的面吹牛锄列,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播惯悠,決...
    沈念sama閱讀 40,271評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼邻邮,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼!你這毒婦竟也來了克婶?” 一聲冷哼從身側(cè)響起筒严,我...
    開封第一講書人閱讀 39,166評(píng)論 0 276
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎情萤,沒想到半個(gè)月后鸭蛙,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,608評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡筋岛,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,814評(píng)論 3 336
  • 正文 我和宋清朗相戀三年娶视,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,926評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡肪获,死狀恐怖寝凌,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情孝赫,我是刑警寧澤较木,帶...
    沈念sama閱讀 35,644評(píng)論 5 346
  • 正文 年R本政府宣布,位于F島的核電站青柄,受9級(jí)特大地震影響伐债,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜刹前,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,249評(píng)論 3 329
  • 文/蒙蒙 一泳赋、第九天 我趴在偏房一處隱蔽的房頂上張望雌桑。 院中可真熱鬧喇喉,春花似錦、人聲如沸校坑。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,866評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽耍目。三九已至膏斤,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間邪驮,已是汗流浹背莫辨。 一陣腳步聲響...
    開封第一講書人閱讀 32,991評(píng)論 1 269
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留毅访,地道東北人沮榜。 一個(gè)月前我還...
    沈念sama閱讀 48,063評(píng)論 3 370
  • 正文 我出身青樓,卻偏偏與公主長得像喻粹,于是被迫代替她去往敵國和親蟆融。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,871評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容