10篇文章 · 24971字 · 2人關(guān)注
-
Flink重點(diǎn)難點(diǎn)：維表關(guān)聯(lián)理論和Join實(shí)戰(zhàn)Flink 案例實(shí)戰(zhàn)演練 Flink維表Join實(shí)踐 常見的維表Join方式有四種： 預(yù)加載維表 熱存儲(chǔ)維表 廣播維表 Temporal tab...
-
kafka+flink 流級(jí)別 順序保證1 已亥、順序保證難點(diǎn) Kafka 作為一款性能優(yōu)秀的消息隊(duì)列，在分布式事務(wù)中有著廣泛地應(yīng)用，其為了做到水平擴(kuò)展，達(dá)到提高并發(fā)的目的，將一個(gè) top...
-
Flink雙流實(shí)時(shí)對(duì)賬
背景 在電商锌历、金融、銀行峦筒、支付等涉及到金錢相關(guān)的領(lǐng)域究西，為了安全起見，一般都有對(duì)賬的需求物喷。 比如卤材，對(duì)于訂單支付事件，用戶通過某寶付款峦失，雖然用戶支付...
-
Flink CDC 原理商膊、實(shí)踐和優(yōu)化CDC 變更數(shù)據(jù)捕獲技術(shù)可以將源數(shù)據(jù)庫(kù)的增量變動(dòng)記錄，同步到一個(gè)或多個(gè)數(shù)據(jù)目的宠进。本文基于騰訊云 Oceanus 提供的 Flink CDC 引擎...
-
超牛逼的性能調(diào)優(yōu)利器 — 火焰圖前言 工具的進(jìn)化一直是人類生產(chǎn)力進(jìn)步的標(biāo)志晕拆，合理使用工具能大大提高我們的工作效率，遇到問題時(shí)材蹬，合理使用工具更能加快問題排查的進(jìn)度实幕。這也是我為什么...
-
Flink | Checkpoint 機(jī)制詳解
一、Checkpoint 簡(jiǎn)介 Flink 的 Checkpoint 機(jī)制是其可靠性的基石堤器。當(dāng)一個(gè)任務(wù)在運(yùn)行過程中出現(xiàn)故障時(shí)昆庇，可以根據(jù) Chec...
-
Flink - 4 大主題、15 個(gè)高頻問題
1.前言 2.狀態(tài)原理 2.1. 狀態(tài)闸溃、狀態(tài)后端整吆、Checkpoint 三者之間的區(qū)別及關(guān)系？ 結(jié)論：拿五個(gè)字做比喻："鐵鍋燉大鵝"辉川，鐵鍋是狀態(tài)...
-
Flink - 8 個(gè)面試高頻實(shí)戰(zhàn)問題
1.前言 解決問題的能力：生產(chǎn)環(huán)境中表蝙，如何快速判斷哪個(gè)算子存在反壓呢？ 解決問題的能力：反壓有哪些危害乓旗？ 解決問題的能力：經(jīng)常碰到哪些問題會(huì)任務(wù)...
-
Flink - toAppendStream與toRetractStream的區(qū)別
前言 通常我們?cè)谛枰敵鯰able表數(shù)據(jù)時(shí)需要轉(zhuǎn)換成DataStream流進(jìn)行輸出府蛇，然后轉(zhuǎn)換流有兩種模式toAppendStream追加模式、t...
