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