一. Flink 1.9 新特性 總的變更：https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=...
IP屬地：北京
-
Flink源碼閱讀（13）--- Flink 不同版本新特性整理 -
Flink源碼閱讀（十）--- Flink 心跳機制
1. 背景 心跳機制通過定期向對方發(fā)送請求方式用于檢測客戶端或者服務端是否存活的一種機制，常見的心跳檢測有兩種：?? 1. socket 套接字 SO_KEEPALIVE 本...
-
Flink源碼閱讀（八）--- Flink SQL 整體執(zhí)行流程為了批流統(tǒng)一，F(xiàn)link提供了兩種關系型API，Table API和SQL。Table API是一種語言集成的查詢API梢杭，由多個比如selection破加，filter，join...
-
Flink源碼閱讀（七）--- Calcite 語法拓展Calcite主要是做SQL解析某筐、校驗、優(yōu)化等工作冠跷，比如Flink南誊、Hive底層都是使用的calcite。本文內容是基于Flink 1.12來講解蜜托。 首先從整體上對Calci...
-
Flink源碼閱讀（五）--- checkpoint / savepoint恢復
Flink源碼閱讀（四）--- checkpoint制作[http://www.reibang.com/p/539dbda544b0]這篇文章介紹了checkpoint制作...
-
Flink源碼閱讀（四）--- checkpoint制作本文內容是基于Flink 1.9來講解抄囚。Flink使用checkpoint檢查點來保證Exactly-Once語義的，這篇文章會從源碼角度分析下checkpoint怎么觸發(fā)的...
-
Flink作業(yè)提交（三）--- Job運行
源碼分析JobMaster如何run起來[http://www.reibang.com/p/24721c268141] 介紹到了JobMaster.start方法橄务，這個方法...
-
Flink源碼閱讀（三）--- ExecutionGraph 的生成
本文內容是基于Flink 1.9來講解幔托。在執(zhí)行Flink任務的時候，會涉及到三個Graph蜂挪，分別是StreamGraph重挑，JobGraph，ExecutionGraph棠涮。其中...
-
Flink源碼閱讀（二）--- JobGraph 的生成
本文內容是基于Flink 1.9來講解谬哀。在執(zhí)行Flink任務的時候，會涉及到三個Graph严肪，分別是StreamGraph史煎，JobGraph，ExecutionGraph驳糯。其中...