IP屬地：北京
-
Flink源碼閱讀（13）--- Flink 不同版本新特性整理一. Flink 1.9 新特性 總的變更：https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=...
-
FlinkSQL 語(yǔ)法擴(kuò)展
FlinkSQL 語(yǔ)法擴(kuò)展 參考flink-sql-parser模塊了解下Flink如何擴(kuò)展Calcite語(yǔ)法神年，創(chuàng)建空項(xiàng)目進(jìn)行語(yǔ)法擴(kuò)展僵控。首先欲间，拷貝codegen文件夾下的內(nèi)容...
-
Flink源碼閱讀（11）--- Flink Task重啟時(shí)機(jī)
本篇文章簡(jiǎn)單總結(jié)下Flink Task重啟時(shí)機(jī) 1. Flink 集群正常 ?? 在Flink集群正常的情況下，只有Task出現(xiàn)異常才會(huì)依據(jù)重啟策略發(fā)生Task重啟敌卓。 2. ...
-
Flink源碼閱讀（十）--- Flink 心跳機(jī)制
1. 背景 心跳機(jī)制通過(guò)定期向?qū)Ψ桨l(fā)送請(qǐng)求方式用于檢測(cè)客戶端或者服務(wù)端是否存活的一種機(jī)制慎式，常見(jiàn)的心跳檢測(cè)有兩種：?? 1. socket 套接字 SO_KEEPALIVE 本...
-
深入理解JVM-內(nèi)存模型（jmm）和GC1 CPU和內(nèi)存的交互 了解jvm內(nèi)存模型前，了解下cpu和計(jì)算機(jī)內(nèi)存的交互情況”窭簦【因?yàn)镴ava虛擬機(jī)內(nèi)存模型定義的訪問(wèn)操作與計(jì)算機(jī)十分相似】 有篇很棒的文章癣防，從cpu講到內(nèi)...
-
Flink源碼閱讀（八）--- Flink SQL 整體執(zhí)行流程為了批流統(tǒng)一，F(xiàn)link提供了兩種關(guān)系型API肪虎，Table API和SQL劣砍。Table API是一種語(yǔ)言集成的查詢(xún)API，由多個(gè)比如selection扇救，filter刑枝，join...
-
-
Flink源碼閱讀（七）--- Calcite 語(yǔ)法拓展Calcite主要是做SQL解析装畅、校驗(yàn)、優(yōu)化等工作沧烈，比如Flink掠兄、Hive底層都是使用的calcite。本文內(nèi)容是基于Flink 1.12來(lái)講解锌雀。 首先從整體上對(duì)Calci...
-
Flink源碼閱讀（六）--- Flink 內(nèi)存模型本篇文章主要介紹下FLink的內(nèi)存模型蚂夕，在介紹Flink內(nèi)存模型之前，我們首先學(xué)習(xí)下JVM內(nèi)存結(jié)構(gòu) 1. JVM內(nèi)存結(jié)構(gòu) Java7 升級(jí)為 Java8的時(shí)候腋逆，JVM內(nèi)存結(jié)構(gòu)...
-
嗯惩歉，是的等脂，學(xué)習(xí)并記錄下
Flink源碼閱讀（四）--- checkpoint制作
本文內(nèi)容是基于Flink 1.9來(lái)講解。Flink使用checkpoint檢查點(diǎn)來(lái)保證Exactly-Once語(yǔ)義的撑蚌，這篇文章會(huì)從源碼角度分析下checkpoint怎么觸發(fā)的...
-
Flink源碼閱讀（五）--- checkpoint / savepoint恢復(fù)
Flink源碼閱讀（四）--- checkpoint制作[http://www.reibang.com/p/539dbda544b0]這篇文章介紹了checkpoint制作...
-
Flink源碼閱讀（四）--- checkpoint制作本文內(nèi)容是基于Flink 1.9來(lái)講解上遥。Flink使用checkpoint檢查點(diǎn)來(lái)保證Exactly-Once語(yǔ)義的，這篇文章會(huì)從源碼角度分析下checkpoint怎么觸發(fā)的...
-
Flink作業(yè)提交（三）--- Job運(yùn)行
源碼分析JobMaster如何run起來(lái)[http://www.reibang.com/p/24721c268141] 介紹到了JobMaster.start方法争涌，這個(gè)方法...
-
Flink源碼閱讀（三）--- ExecutionGraph 的生成
本文內(nèi)容是基于Flink 1.9來(lái)講解粉楚。在執(zhí)行Flink任務(wù)的時(shí)候，會(huì)涉及到三個(gè)Graph亮垫，分別是StreamGraph解幼，JobGraph，ExecutionGraph包警。其中...
-
Flink源碼閱讀（二）--- JobGraph 的生成
本文內(nèi)容是基于Flink 1.9來(lái)講解。在執(zhí)行Flink任務(wù)的時(shí)候底靠，會(huì)涉及到三個(gè)Graph害晦，分別是StreamGraph，JobGraph，ExecutionGraph壹瘟。其中...
-
Flink源碼閱讀（一）--- StreamGraph 的生成
本文內(nèi)容是基于Flink 1.9來(lái)講解鲫剿。在執(zhí)行Flink任務(wù)的時(shí)候，會(huì)涉及到三個(gè)Graph稻轨，分別是StreamGraph灵莲，JobGraph，ExecutionGraph殴俱。其中...
-
go-gin源碼(一)
hello world 使用Gin實(shí)現(xiàn)Hello world非常簡(jiǎn)單政冻，創(chuàng)建一個(gè)router，然后使用其Run的方法： Default函數(shù) 函數(shù)返回一個(gè)默認(rèn)的框架引擎线欲，從函數(shù)實(shí)...
