本文對 Flink 的 Application、Per-Job 和 Session 部署模式進(jìn)行了對比分析。詳細(xì)介紹了 Native Kuber...
投稿
收錄了20篇文章 · 47人關(guān)注
-
【Flink on k8s】Native Kubernetes Application 部署模式詳解 -
【Flink SQL】Apache Calcite 架構(gòu)剖析1.簡介和架構(gòu) Apache Calcite[https://calcite.apache.org/docs/] 是一個(gè)動態(tài)的數(shù)據(jù)管理框架, 可...
-
【Flink SQL】如何利用 Calcite 擴(kuò)展 Flink Function 語法
1.Calcite 如何實(shí)現(xiàn) sql 語法的解析 Calcite 使用 javacc 作為語法解析器[https://zhuanlan.zhih...
-
【Flink SQL】如何解析和校驗(yàn) Flink SQL
1.flink sql 解析 方法1：直接創(chuàng)建 flink sql parser 解析多行 sql 方法2：通過 table env 獲取的 f...
-
【Flink on k8s】高可用的關(guān)鍵機(jī)制及configmap數(shù)據(jù)詳解
1.高可用的關(guān)鍵機(jī)制 源碼詳解：DefaultCompletedCheckpointStore.addCheckpoint/tryRemoveC...
-
【Flink 精選】Flink-1.10 內(nèi)存調(diào)優(yōu)實(shí)踐1.JobManager 內(nèi)存調(diào)優(yōu) 1.1 JobManager 內(nèi)存模型的介紹 JobManager 是 Java 進(jìn)程，從 JVM 角度來看...
-
【Flink on k8s】JConsole 遠(yuǎn)程監(jiān)控 TaskManager問題：如何定位 Flink 作業(yè)卡在哪里？ 首先，配置文件 flink-conf.yaml 添加 Java RMI 遠(yuǎn)程調(diào)度，打開容器的本地 I...
-
【Flink on k8s】Flink on Kubernetes 部署模式本文基于 Flink-1.13 介紹 Flink on Kubernetes 的部署模式，重點(diǎn)講述 Session 和 Native Sessi...
-
【Flink 精選】TaskManager 詳解 — 架構(gòu)本文重點(diǎn)介紹 TaskManager 總體架構(gòu)。TaskManager 整體是一個(gè) RPC 服務(wù)端，提供的接口，例如請求 slot、提交任務(wù)、取...
-
【Flink 精選】Kafka Consumer 源碼詳解本文首先進(jìn)行 Flink Kafka Consumer 原理分析，結(jié)合 SourceFunction 和 Kafka Client API 詳解...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1918726/flink%E5%9B%BE%E6%A0%87.jpg', '推薦專題《Flink精選學(xué)習(xí)》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/dbce613b6f2e?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}