發(fā)簡信
IP屬地：廣東
-
Flink SQL 實戰(zhàn)之 MAP 類型在 UNION ALL 中的妙用
前言 工作當中我們往往會遇到這樣的需求場景：某張表中不同的統(tǒng)計指標，需要從多個不同的 kafka 數(shù)據(jù)源當中統(tǒng)計匿醒。這種做法弛姜，我們很容易想到把多個...
-
Flink State機制源碼解析在流計算中，事件會持續(xù)不斷的產(chǎn)生，如果每次計算都是相互獨立的，不依賴于上下游事件，則稱為無狀態(tài) (stateless) 計算丸边；如果每次的計算依賴...
-
Flink如何管理Kafka 消費位點(譯文)Checkpointing 是 Flink 故障恢復的內(nèi)部機制。一個 checkpoint 就是 Flink應用程序產(chǎn)生的狀態(tài)的一個副本荚孵。如果 ...
-
Windows環(huán)境下編譯Flink文檔
環(huán)境準備 安裝Docker for Windows安裝方法可以參考Docker官方文檔[https://docs.docker.com/dock...
-
Flink-CDC(Change Data Capture)指定位點消費binlog
前言： Flink從1.10開始支持從canal或者debezium消費binlog數(shù)據(jù)妹窖，從而實現(xiàn)數(shù)據(jù)的同步；但是無論是canal和debezi...
-
解決Flink1.11.0不能指定SQL任務JobName問題前言： Flink最近剛發(fā)布了1.11.0版本收叶，由于加了很多新的功能骄呼，對sql的支持更加全面，我就迫不及待的在本地運行了個demo判没，但是運行的時...
-
不借助于Flink集群蜓萄，如何讓任務本地執(zhí)行
前言：在做flink實時計算平臺的時候，我遇到過這樣一個問題澄峰，在執(zhí)行sql任務的時候嫉沽，我們需要預先創(chuàng)建一些Table,View，甚至是funct...
-
Flink知識圖譜整理 - 基本概念和架構Streaming Processing Concepts(流處理基本概念) Bounded and UnBounded Data and Pr...