當(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ù)。
Flink任務(wù)提交流程
Flink任務(wù)提交流程
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
- 文/潘曉璐 我一進(jìn)店門艳丛,熙熙樓的掌柜王于貴愁眉苦臉地迎上來匣掸,“玉大人趟紊,你說我怎么就攤上這事∨鲈停” “怎么了霎匈?”我有些...
- 文/不壞的土叔 我叫張陵,是天一觀的道長送爸。 經(jīng)常有香客問我铛嘱,道長,這世上最難降的妖魔是什么袭厂? 我笑而不...
- 正文 為了忘掉前任墨吓,我火速辦了婚禮,結(jié)果婚禮上纹磺,老公的妹妹穿的比我還像新娘帖烘。我一直安慰自己,他們只是感情好橄杨,可當(dāng)我...
- 文/花漫 我一把揭開白布秘症。 她就那樣靜靜地躺著,像睡著了一般式矫。 火紅的嫁衣襯著肌膚如雪乡摹。 梳的紋絲不亂的頭發(fā)上,一...
- 文/蒼蘭香墨 我猛地睜開眼邻邮,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼!你這毒婦竟也來了克婶?” 一聲冷哼從身側(cè)響起筒严,我...
- 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎情萤,沒想到半個(gè)月后鸭蛙,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
- 正文 獨(dú)居荒郊野嶺守林人離奇死亡筋岛,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
- 正文 我和宋清朗相戀三年娶视,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
- 正文 年R本政府宣布,位于F島的核電站青柄,受9級(jí)特大地震影響伐债,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜刹前,卻給世界環(huán)境...
- 文/蒙蒙 一泳赋、第九天 我趴在偏房一處隱蔽的房頂上張望雌桑。 院中可真熱鬧喇喉,春花似錦、人聲如沸校坑。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽耍目。三九已至膏斤,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間邪驮,已是汗流浹背莫辨。 一陣腳步聲響...
- 正文 我出身青樓,卻偏偏與公主長得像喻粹,于是被迫代替她去往敵國和親蟆融。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
推薦閱讀更多精彩內(nèi)容
- 本文為《Flink大數(shù)據(jù)項(xiàng)目實(shí)戰(zhàn)》學(xué)習(xí)筆記守呜,想通過視頻系統(tǒng)學(xué)習(xí)Flink這個(gè)最火爆的大數(shù)據(jù)計(jì)算框架的同學(xué)型酥,推薦學(xué)習(xí)...
- 1.Flink架構(gòu)及特性分析 Flink是個(gè)相當(dāng)早的項(xiàng)目玛迄,開始于2008年由境,但只在最近才得到注意。Flink是原生...
- 這將是一套完整詳細(xì)且持續(xù)更新的憔晒、長期維護(hù)的 原創(chuàng) Flink系列教程藻肄、文檔蔑舞,其中會(huì)包含各種商用實(shí)例詳解、Flin...
- Flink系統(tǒng)組成 Flink是一個(gè)分層系統(tǒng)嘹屯,從下到上分為:系統(tǒng)部署層攻询、任務(wù)運(yùn)行層、API層以及基于API開發(fā)的通...
- 練習(xí)步驟: 1. 觀察:發(fā)生了什么事情州弟? 幾天前钧栖,手機(jī)收到短信提醒,這個(gè)月的流量只剩80M了婆翔。在看了已經(jīng)使用流量的...