9個超省時的管理面板構(gòu)架工具，速度提高10倍 2022-09-14
構(gòu)建管理面板是一項耗時的任務(wù)。大量的后端工作是為了設(shè)置基本和高級組件，這就是為什么很多時候你看到公司稱自己為“開發(fā)人員”，但只回答基...詳情>
如何從零開始學(xué)編程 2022-09-06
隨著互聯(lián)網(wǎng)行業(yè)的快速發(fā)展，很多人都想進入到互聯(lián)網(wǎng)行業(yè)，大部分學(xué)員都是從零基礎(chǔ)開始，如何從零開始學(xué)編程?這個問題成了大家都比較關(guān)注的一個...詳情>
Flink支持的時間語義 ？ 2022-09-02
Spark Streaming只支持 Processing Time， Flink 支持三種時間語義， Processing Time, Event Time, Ingestion Time - Processing Time 數(shù)據(jù)被...詳情>
Flink Slot和Parallelism區(qū)別是什么？ 2022-09-02
Slot是指TaskManager的并發(fā)執(zhí)行能力，如果代碼運行前我們將slot的個數(shù)配置為3（taskmanager.numberOfTaskSlots） ，那么每個TaskManager會分配...詳情>
Flink checkpoint和savepoint區(qū)別 2022-09-02
Checkpoint是為runtime準(zhǔn)備的，Savepoint 是為用戶準(zhǔn)備的。Checkpoint 機制的目標(biāo)在于保證Flink作業(yè)意外崩潰重啟不影響exactly once 準(zhǔn)確性，...詳情>
Flink State？ 2022-09-02
State：指一個具體的Task/Operator的狀態(tài)。State可以被記錄，在失敗的情況下數(shù)據(jù)還可以恢復(fù)，F(xiàn)link中有兩種基本類型的State： Keyed State， O...詳情>
Flink反壓機制？ 2022-09-02
Flink 內(nèi)部是基于producer-consumer模型來進行消息傳遞的，F(xiàn)link的反壓設(shè)計也是基于這個模型。Flink 使用了高效有界的分布式阻塞隊列，就像 Ja...詳情>
Flink & Spark Streaming區(qū)別？ 2022-09-02
時間機制，Spark Streaming 只支持Processing Time(處理時間), 而Flink支持更為豐富的時間語義 Processing Time(處理時間),Ingestion Time(攝...詳情>
大數(shù)據(jù)面數(shù)據(jù)：Flink Allowed Lateness & Side OutPut？ 2022-09-02
雖說水位線(Watermark)表明早于它的事件不應(yīng)該再出現(xiàn)，但是接收到水位線以前的的消息是不可避免的，這就是所謂的遲到事件。實際上遲到事件是亂...詳情>
Flink兩階段提交(2PC) 2022-09-02
借助一個文件寫入的例子來說明兩階段提交，在Flink中使用兩階段提交，需要實現(xiàn)TwoPhaseCommitSinkFunction這個抽象類的四個方法，我們下面來說...詳情>
熱問標(biāo)簽 更多>>
在線提問
專業(yè)導(dǎo)師線上坐鎮(zhèn)，解答個性化學(xué)習(xí)難題
提交問題
京公網(wǎng)安備 11010802030320號