flink源碼閱讀（概覽）
clone官方1.6.2版本flink，成功編譯。（一般PC還真跑不動，我是用服務器編譯的） 編譯完后，略微修改了一下啟動腳本后，成功跑起來。 sh bin/start-cluster.sh 紅色部分是我改過的地方： vim start-cluster.sh bin=`dirname ...
原文：Flink源碼閱讀(1.7.2)
目錄 Client提交任務 flink的圖結構 StreamGraph OptimizedPlan JobGraph ExecutionGraph flink部署與執行模型 Single Job JobManager ResourceManager TaskManager YARN Dispatcher JobMaster YarnTaskExecutorRunner 源碼分析 flink源碼閱 ...
2019-03-21 21:49 0 2556 推薦指數：
相關推薦
flink源碼閱讀（2）
Flink面試--源碼篇 1、Flink Job的提交流程？ 2、Flink所謂"三層圖"結構是哪幾個"圖"？ 3、JobManger在集群中扮演了什么角色？ 4、JobManger在集群啟動過程中起到什么作用 ...
flink 1.7.2 安裝詳解
##flink 1.7.2 安裝需要java環境 下載地址 https://flink.apache.org/downloads.html#1、單機版 #創建用戶flinkuseradd flink -d /home/flinkecho "flink123" | passwd flink ...
Flink源碼閱讀（二）——checkpoint源碼分析
前言 在Flink原理——容錯機制一文中，已對checkpoint的機制有了較為基礎的介紹，本文着重從源碼方面去分析checkpoint的過程。當然本文只是分析做checkpoint的調度過程，只是盡量弄清楚整體的邏輯，沒有弄清楚其實現細節，還是有遺憾的，后期還是努力去分析實現細節。文中 ...
Flink源碼閱讀（一）--Checkpoint觸發機制
Checkpoint觸發機制 Flink的checkpoint是通過定時器周期性觸發的。checkpoint觸發最關鍵的類是CheckpointCoordinator，稱它為檢查點協調器。 CheckpointCoordinator主要作用是協調operators ...
Flink1.7.2安裝部署的幾種方式
原文鏈接：https://blog.csdn.net/a_drjiaoda/article/details/88037282 前言：Flink的運行一般分為三種模式，即local、Standalone、On Yarn。 在安裝Flink之前，需要對安裝環境進行檢查。本文是建立在 ...
Flink源碼閱讀（一）——Per-job之Yarn的作業調度（一）
1、前言 Flink作業提交到Yarn上之后，后續的AM的生成、Job的處理過程和Flink基本沒什么關系了，但是為大致了解Flink on yarn的Per-Job模式的整體過程，這里還是將這系列博客歸到Flink源碼閱讀系列了，本系列博客計划三篇。 本文着重分析 ...
Flink源碼閱讀（一）——Flink on Yarn的Per-job模式源碼簡析
一、前言 個人感覺學習Flink其實最不應該錯過的博文是Flink社區的博文系列，里面的文章是不會讓人失望的。強烈安利：https://ververica.cn/developers-resources/。 本文是自己第一次嘗試寫源碼閱讀的文章，會努力將原理和源碼實現流程結合起來 ...