Flink源碼閱讀(1.7.2)
目錄 Client提交任務 flink的圖結構 StreamGraph OptimizedPlan JobGraph ExecutionGraph flink部署與執行模型 Single Job ...
原文：flink源碼閱讀（概覽）
clone官方 . . 版本flink，成功編譯。 一般PC還真跑不動，我是用服務器編譯的 編譯完后，略微修改了一下啟動腳本后，成功跑起來。 sh bin start cluster.sh 紅色部分是我改過的地方： vimstart cluster.sh bin dirname bin cd bin pwd FLINK BIN DIR bincd bin . config.sh 啟動成功后就可以看 ...
2018-10-30 18:33 0 1311 推薦指數：
相關推薦
flink源碼閱讀（2）
Flink面試--源碼篇 1、Flink Job的提交流程？ 2、Flink所謂"三層圖"結構是哪幾個"圖"？ 3、JobManger在集群中扮演了什么角色？ 4、JobManger在集群啟動過程中起到什么作用 ...
Flink源碼閱讀（二）——checkpoint源碼分析
前言 在Flink原理——容錯機制一文中，已對checkpoint的機制有了較為基礎的介紹，本文着重從源碼方面去分析checkpoint的過程。當然本文只是分析做checkpoint的調度過程，只是盡量弄清楚整體的邏輯，沒有弄清楚其實現細節，還是有遺憾的，后期還是努力去分析實現細節。文中 ...
Flink源碼閱讀（一）--Checkpoint觸發機制
Checkpoint觸發機制 Flink的checkpoint是通過定時器周期性觸發的。checkpoint觸發最關鍵的類是CheckpointCoordinator，稱它為檢查點協調器。 CheckpointCoordinator主要作用是協調operators ...
Flink源碼閱讀（一）——Flink on Yarn的Per-job模式源碼簡析
一、前言 個人感覺學習Flink其實最不應該錯過的博文是Flink社區的博文系列，里面的文章是不會讓人失望的。強烈安利：https://ververica.cn/developers-resources/。 本文是自己第一次嘗試寫源碼閱讀的文章，會努力將原理和源碼實現流程結合起來 ...
Flink源碼閱讀（一）——Per-job之Yarn的作業調度（一）
1、前言 Flink作業提交到Yarn上之后，后續的AM的生成、Job的處理過程和Flink基本沒什么關系了，但是為大致了解Flink on yarn的Per-Job模式的整體過程，這里還是將這系列博客歸到Flink源碼閱讀系列了，本系列博客計划三篇。 本文着重分析 ...
groupcache源碼解析-概覽
接下來講什么 今天開始講groupcache！ Memcached大家應該都不陌生，官網的介紹是： Free & open source, high-performance, ...
Flink源碼閱讀 - K8s上部署session模式的集群(入口配置)
啟動主類 KubernetesSessionCli KubernetesSessionCli#mian 主類入口 // org.apache.flink.kubernetes.cli.KubernetesSessionCli#main public static void main ...