-
甘特圖怎么制作更方便？甘特圖制作方法" title="甘特圖怎么制作更方便？甘特圖制作方法" width="200" height="150">
-
OKR的實(shí)施標(biāo)準(zhǔn)步驟是什么？成功實(shí)施落地OKR的要點(diǎn)" title="OKR的實(shí)施標(biāo)準(zhǔn)步驟是什么？成功實(shí)施落地OKR的要點(diǎn)" width="200" height="150">
-
Apache Flink 進(jìn)階（三）：Checkpoint 原理解析與應(yīng)用實(shí)踐
所有內(nèi)容 ?2022-05-29簡介： 大家好，今天我將跟大家分享一下 Flink 里面的 Checkpoint，共分為四個(gè)部分。 Checkpoint 是從 source 觸發(fā)到下游所有節(jié)點(diǎn)完成的一次全局操作。下圖可以有一個(gè)對 C...
-
Apache Flink 進(jìn)階（四）：Flink on Yarn/K8s 原理剖析及實(shí)踐
所有內(nèi)容 ?2022-05-29image.png 用戶通過 DataStream API、DataSet API、SQL 和 Table API 編寫 Flink 任務(wù)，它會(huì)生成一個(gè)JobGraph。JobGraph 是由 sou...
-
Flink狀態(tài)管理與Checkpoint實(shí)戰(zhàn)——模擬電商訂單計(jì)算過程中宕機(jī)的場景，探索宕機(jī)恢復(fù)時(shí)如何精準(zhǔn)繼續(xù)計(jì)算訂單
所有內(nèi)容 ?2022-05-29Flink的狀態(tài)與容錯(cuò)是這個(gè)框架很核心的知識點(diǎn)。其中一致檢查點(diǎn)也就是Checkpoints也是Flink故障恢復(fù)機(jī)制的核心，這篇文章將詳細(xì)介紹Flink的狀態(tài)管理和Checkpoints的概念以及在生...
-
Flink知識學(xué)習(xí)（9）
所有內(nèi)容 ?2022-05-28在流處理引擎之上，F(xiàn)link 有以下機(jī)制： 檢查點(diǎn)機(jī)制和狀態(tài)機(jī)制：用于實(shí)現(xiàn)容錯(cuò)、有狀態(tài)的處理； 水印機(jī)制：用于實(shí)現(xiàn)事件時(shí)鐘； 窗口和觸發(fā)器：用于限制計(jì)算范圍，并定義呈現(xiàn)結(jié)果的時(shí)間。 在同一個(gè)流處理引擎...
-
05_說說Flink架構(gòu)中的角色和作用？
所有內(nèi)容 ?2022-05-28image.png JobManager： 類似于經(jīng)理 JobManager是Flink系統(tǒng)的協(xié)調(diào)者，它負(fù)責(zé)接收Flink Job，調(diào)度組成Job的多個(gè)Task的執(zhí)行。同時(shí)，JobManager還負(fù)責(zé)...
-
Flink知識學(xué)習(xí)（20）
所有內(nèi)容 ?2022-05-28在啟動(dòng) Checkpoint 機(jī)制時(shí)，狀態(tài)會(huì)隨著 Checkpoint 而持久化，以防止數(shù)據(jù)丟失，保障恢復(fù)時(shí)的一致性。狀態(tài)內(nèi)部的存儲(chǔ)格式、狀態(tài)在 Checkpoint 時(shí)如何持久化以及持久化在哪里，均...
