IP屬地：山西
-
-
Flink?狀態(tài)作業(yè)調優(yōu)實踐指南：Flink SQL 作業(yè)篇摘要：本文整理自俞航翔、陳婧敏、黃鵬程老師所撰寫的大狀態(tài)作業(yè)調優(yōu)實踐指南。由于內容豐富，本文中篇內容分享 Flink SQL 作業(yè)大狀態(tài)導致反壓的調優(yōu)原理與方法，主要分為以下...
-
關于使用Flink RocksDB狀態(tài)后端時一定要寫MapState而非ValueState<Map>這檔事（以及解決方法）前言 抱歉起這種爛大街的日本輕小說風格標題來吸引注意力。原本我認為這是常識，不需要專門寫一篇文章來講解如此細碎的點。但是在最近工作巡檢中發(fā)現(xiàn)了越來越多如同ValueState...
-
從一例狀態(tài)引發(fā)的性能問題談Flink狀態(tài)序列化前言 好久不見（鞠躬 最近處在轉型期，每天忙到飛起，關注具體技術細節(jié)的精力自然就比較少了（上一篇許下的周更承諾也食言了 = =）。上周幫助他人快速解決了一個因誤用Flink狀...
-
Flink 源碼之AsyncFunction
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://www.itdecent.cn/p/d4a372809e3d] 簡介 Flink的特...
-
Flink 使用之 SQL UDF
Flink 使用介紹相關文檔目錄 Flink 使用介紹相關文檔目錄[http://www.itdecent.cn/p/74f1990d047c] 簡介 在使用純Flink ...
-
Flink 源碼之 LookupTableSource
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://www.itdecent.cn/p/d4a372809e3d] 簡介 Flink一個...
-
【Flink SQL】如何利用 Calcite 擴展 Flink Function 語法
1.Calcite 如何實現(xiàn) sql 語法的解析 Calcite 使用 javacc 作為語法解析器[https://zhuanlan.zhihu.com/p/5096817...
-
【Flink SQL】如何解析和校驗 Flink SQL
1.flink sql 解析 方法1：直接創(chuàng)建 flink sql parser 解析多行 sql 方法2：通過 table env 獲取的 flink sql parser...
-
新一代緩存Caffeine，速度確實比Guava的Cache快
來自公眾號：小姐姐味道作者：小姐姐養(yǎng)的狗作者簡介：小姐姐味道 (xjjdog)，一個不允許程序員走彎路的公眾號。聚焦基礎架構和Linux。十年架構，日百億流量，與你探討高并...
-
深入分析Flink的operator chain（算子鏈）機制前言 這篇是昨晚沒寫完的，今晚補全發(fā)出來。 Flink算子鏈簡介 “為什么我的Flink作業(yè)Web UI中只顯示出了一個框，并且Records Sent和Records Re...
-
-
Flink 快照分析：定位大狀態(tài)和數(shù)據(jù)傾斜的算子
在 Flink 作業(yè)中，無論是 SQL 還是 JAR 模式，常常會直接或者間接地使用到狀態(tài)（State）。當 Flink 進行快照時，用戶定義的這些狀態(tài)數(shù)據(jù)可以被保存在狀態(tài)點...
-
Flink新特性之網(wǎng)絡緩存消脹（Network Buffer Debloating）機制前言 最近正在準備關于Flink 1.13 / 1.14版本新特性的內部分享，順便做點記錄。 又見網(wǎng)絡緩存 很久沒有聊過Flink的網(wǎng)絡棧了，但相信大家對網(wǎng)絡緩存（Netwo...
-
Flink流量控制與反壓機制完全總結前言 筆者最近回顧自己對Flink技術棧細節(jié)的理解，發(fā)現(xiàn)對Flink的網(wǎng)絡棧、流控與反壓這一套機制存在比較大的盲區(qū)。雖然平時多次處理過作業(yè)反壓的問題，但是不完全理解背后的實現(xiàn)...
-
手寫理解Callable,Future,Executor
前言 Callable,Future,Executor都是java.util.concurrent包下的工具類，作者李二狗，為了徹底吃透它們的概念，今天就假設這些類都不存在，...
-
G1垃圾收集器實現(xiàn)原理1 與垃圾收集器有關的算法 在分析G1前先簡單回顧一下與垃圾收集器相關的算法。通常所謂的垃圾收集器更多地是指跟蹤垃圾收集器（Tracing Garbage Collectio...
-
知識回顧｜并發(fā)｜ThreadLocal、ThreadPoolExecutor本文回答以下問題，文內可能有遺漏、錯誤或表達不夠清晰的地方。 ThreadLocal① 了解ThreadLocal使用場景和內部實現(xiàn)② 使用ThreadLocal時要注意什么...
-
