曾經(jīng)紅遍一時的Scala 想當(dāng)初Spark橫空出世之后，Scala簡直就是語言界的一顆璀璨新星，惹得大家紛紛側(cè)目，連Kafka這類技術(shù)框架也選擇...
投稿
收錄了176篇文章 · 20人關(guān)注
-
為什么 Flink 拋棄了 Scala
-
Flink 源碼之 LookupTableSource
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://m.itdecent.cn/p/d4a372809...
-
Apache Flink——數(shù)據(jù)源算子（Source）前言 Flink 可以從各種來源獲取數(shù)據(jù)，然后構(gòu)建 DataStream 進(jìn)行轉(zhuǎn)換處理。一般將數(shù)據(jù)的輸入來源稱為數(shù)據(jù)源(data source)...
-
Flink CDC 原理、實踐和優(yōu)化CDC 變更數(shù)據(jù)捕獲技術(shù)可以將源數(shù)據(jù)庫的增量變動記錄，同步到一個或多個數(shù)據(jù)目的。本文基于騰訊云 Oceanus 提供的 Flink CDC 引擎...
-
Flink運(yùn)行jar時的programArgs設(shè)置問題1. 環(huán)境說明 flink 2.12(scala)-1.14.2 flink集群以session模式運(yùn)行在YARN上 2. programArg...
-
Apache Flink——輸出算子（Sink）前言 Flink 作為數(shù)據(jù)處理框架，最終還是要把計算處理的結(jié)果寫入外部存儲，為外部應(yīng)用提供支持。我們已經(jīng)了解了 Flink 程序如何對數(shù)據(jù)進(jìn)行讀...
-
Flink水印不能觸發(fā)窗口計算問題詳解遇到的問題 按道理 窗口為4s,允許最大延遲是3s，那么當(dāng)?shù)谝粭l數(shù)據(jù)01,1586489566000–2020-04-10 11:32:46進(jìn)來...
-
記一次 Flink 反壓問題排查過程問題出現(xiàn) 根據(jù)subtask的watermark發(fā)現(xiàn)延遲了10幾分鐘，然后查看是否有異常或者BackPressure的情況最終發(fā)現(xiàn)，source...
-
Flink 源碼之 Distributed Cache
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://m.itdecent.cn/p/d4a372809...
-
Flink SQL 性能優(yōu)化實戰(zhàn)緣起 最近我們組在大規(guī)模上線Flink SQL作業(yè)。首先，在進(jìn)行跑批量初始化完歷史數(shù)據(jù)后，剩下的就是消費(fèi)Kafka歷史數(shù)據(jù)進(jìn)行追數(shù)了。但是發(fā)現(xiàn)某...
{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/1736101/a.png', '推薦專題《Flink》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/b6089c70072f?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}