Flink介紹： 很多人可能都是在 2015 年才聽到 Flink 這個詞探赫，其實早在 2008 年墓陈，F(xiàn)link 的前身已經(jīng)是柏林理工大學(xué)一個研究...

最近flink job出現(xiàn)了背壓的問題, 后果是導(dǎo)致了checkpoint的生成超時, 影響了flink job的運(yùn)行. 定位問題: 如下圖: ...

前言：前段時間因為項目需求，需要開發(fā)一個實時采集分析日志的任務(wù)，最后選擇的計算框架是Flink所计。項目完成后，基本上就沒再接觸团秽。但總覺得既然用過了...

Flink實現(xiàn)Kafka到Mysql的Exactly-Once 背景 最近項目中使用Flink消費(fèi)kafka消息主胧，并將消費(fèi)的消息存儲到mysql...

Blink First Time & Flink-sql 背景 blink開源，目前在https://github.com/apache/fli...

看了 BucketSink 的相關(guān)源碼夷都。著重看了它的checkpoint以及故障恢復(fù)機(jī)制。把大概的理解梳理如下：BucketSink 大體的工作...

Flink on yarn部署模式 背景 Flink是一個高性能予颤，高吞吐囤官，低延遲的流處理框架。它不僅僅是作為一個流式處理框架蛤虐，更將批處理統(tǒng)一了起...

Flink on yarn運(yùn)行python程序 Flink本地local模式運(yùn)行python程序 參考官網(wǎng)寫了python程序Adder.py(...