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