IP屬地：廣東
-
記錄hadoop一次奇怪的問題操作今天早上，我啟動Hadoop ，然后訪問 9870端口，顯示的卻是這樣的 image.png 剛開始，我以為我哪里配置有問題，于是查看日志，例如...
-
Flink 錯誤日志記錄
異常：Producer attempted to produce with an old epoch. 解決方式 規(guī)避方式[https://is...
-
cdh 安裝 elsticsearch前言 記錄了我使用CDH 安裝 ES 過程 第一步：cdh 集成 es 參考文章[https://blog.csdn.net/guoliduo/...
-
maxwell 啟停腳本
前言 我已經很久沒有寫過博客了，今天再次登錄之后發(fā)現(xiàn)有了很多的關注和評論，讓我感到我的文章的對大家還是有幫助的，以后會繼續(xù)寫下去的，進入主題。我...
-
Flink 定時器
定時器 基于處理時間或者事件時間處理過一個元素之后, 注冊一個定時器, 然后指定的時間執(zhí)行. Context和OnTimerContext 所持...
-
Flink狀態(tài)編程介紹 有狀態(tài)的計算是流處理框架要實現(xiàn)的重要功能，因為稍復雜的流處理場景都需要記錄狀態(tài)，然后在新流入數(shù)據(jù)的基礎上不斷更新狀態(tài)。 SparkStre...
-
Flink 的window機制(二) 窗口函數(shù)
Window Function 前面指定了窗口的分配器, 接著我們需要來指定如何計算, 這事由window function來負責. 一旦窗口關...
-
Flink1.13 容錯機制
狀態(tài)的一致性 當在分布式系統(tǒng)中引入狀態(tài)時，自然也引入了一致性問題。 一致性實際上是"正確性級別"的另一種說法，也就是說在成功處理故障并恢復之后得...
-
Flink1.13 Checkpoint原理
介紹 Flink具體如何保證exactly-once呢? 它使用一種被稱為"檢查點"（checkpoint）的特性，在出現(xiàn)故障時將系統(tǒng)重置回正確...