IP屬地：四川
-
presto入門presot要解決的問題 這些系統(tǒng)不允許你使用標(biāo)準(zhǔn)工具來查詢和檢視數(shù)據(jù)。面向特定系統(tǒng)的查詢語言和分析工具比比皆是。 然而商業(yè)分析師已習(xí)慣使用業(yè)界...
-
如何閱讀
1.這本書大概講什么？ 2.這本書細(xì)節(jié)講什么？ 3.它講得有道理嗎？ 4.它和我有什么關(guān)系？
-
StreamGraph生成例子 如SocketWindowWordCount例子為例，分析Graph的構(gòu)建過程； 如代碼，整個算子鏈執(zhí)行流程如下圖所示：其中在算子構(gòu)成過程...
-
Job的提交流程（一）一個Flink作業(yè)，從client提交到真正的執(zhí)行，其 Graph 的轉(zhuǎn)換會經(jīng)過下面三個階段（第四個階段是作業(yè)真正執(zhí)行時的狀態(tài)，都是以 task...
-
Flink源碼-集群啟動-ResourceMangaer啟動ResourceManger負(fù)責(zé)任務(wù)Slot的申請，其中主要是內(nèi)部的SlotManager管理Slot,下邊分析下RM的啟動過程。 核心主要是啟...
-
Flink-application運(yùn)行模式詳解本文目的： 針對main()方法在ApplicationClusterEntryPoint入口類中執(zhí)行，從源碼角度解析 首先和其他集群比對 例如...
-
Flink三種運(yùn)行模式分析Flink運(yùn)行模式有三種：session、per-job、Application。其中三者核心區(qū)別點(diǎn)：1. 集群的生命周期和資源管理隔離程度 ...
-
Flink源碼-集群啟動之JobManager啟動續(xù)Dispatcher啟動 Dispatcher啟動流程嵌套較多，主要會啟動Dispatcher組件，同時拉起jobmaster;附上詳細(xì)的嵌套圖...
-
Flink源碼-集群啟動之JobManager的啟動主要內(nèi)容 首先要熟悉flink架構(gòu)基礎(chǔ)知識，了解client、jobmanager、taskmanager的基本用途；本文通過源碼角度分析各個組...