摘要：本文整理自俞航翔、陳婧敏、黃鵬程老師所撰寫的大狀態(tài)作業(yè)調(diào)優(yōu)實踐指南。由于內(nèi)容豐富，本文中篇內(nèi)容分享 Flink SQL 作業(yè)大狀態(tài)導致反壓的調(diào)優(yōu)原理與方法，主要分為以下...
IP屬地：山西
-
Flink?狀態(tài)作業(yè)調(diào)優(yōu)實踐指南：Flink SQL 作業(yè)篇 -
關(guān)于使用Flink RocksDB狀態(tài)后端時一定要寫MapState而非ValueState<Map>這檔事（以及解決方法）前言 抱歉起這種爛大街的日本輕小說風格標題來吸引注意力。原本我認為這是常識，不需要專門寫一篇文章來講解如此細碎的點。但是在最近工作巡檢中發(fā)現(xiàn)了越來越多如同ValueState...
-
從一例狀態(tài)引發(fā)的性能問題談Flink狀態(tài)序列化前言 好久不見（鞠躬 最近處在轉(zhuǎn)型期，每天忙到飛起，關(guān)注具體技術(shù)細節(jié)的精力自然就比較少了（上一篇許下的周更承諾也食言了 = =）。上周幫助他人快速解決了一個因誤用Flink狀...
-
Flink 源碼之AsyncFunction
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://www.itdecent.cn/p/d4a372809e3d] 簡介 Flink的特...
-
Flink 使用之 SQL UDF
Flink 使用介紹相關(guān)文檔目錄 Flink 使用介紹相關(guān)文檔目錄[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)，一個不允許程序員走彎路的公眾號。聚焦基礎(chǔ)架構(gòu)和Linux。十年架構(gòu)，日百億流量，與你探討高并...
