前言 Flink的檢查點和恢復機制定期的會保存應用程序狀態(tài)的一致性檢查點。在故障的情況下，應用程序的狀態(tài)將會從最近一次完成的檢查點恢復，并繼續(xù)處...
投稿
收錄了14篇文章 · 2人關注
-
Flink 端對端一致性 -
【Flink 精選】如何排查 Checkpoint 異常問題？本文詳解 Checkpoint 機制，分享 Checkpoint 問題排查的手段，包括失敗、延期等問題。 1.Checkpoint 機制 1.1...
-
Flink新特性之非對齊檢查點（unaligned checkpoint）簡介前言 在食用本文之前，建議看官先充分食用這兩篇文章：《Chandy-Lamport分布式快照算法小記》與《深入理解Flink的輕量級異步屏障快照...
-
Apache Flink 進階（三）：Checkpoint 原理解析與應用實踐簡介： 大家好，今天我將跟大家分享一下 Flink 里面的 Checkpoint，共分為四個部分。 首先講一下 Checkpoint 與 sta...
-
Flink 遲到元素的處理
前言 前面文章Flink中的時間語義 和WaterMark有詳細介紹過Flink WaterMark。WaterMark的出現(xiàn)是用來解決亂序時間...
-
Flink kafka connector
1.kafka connector版本選取 Flink有多個Kafka connector：universal，0.10和0.11。 Flink...
-
10.flink-1.11.1 安裝部署1 Standalone模式 1.0 集群規(guī)劃 node06node07node08node10TaskManagerTaskManagerT...
-
Flink 架構1.Flink 運行時的角色 Flink系統(tǒng)架構中包含了兩個角色，分別是JobManager和TaskManager，是一個典型的Master-...
-
Flink中的時間語義 和WaterMark1. Flink 時間語義 Flink定義了三類時間 處理時間（Process Time）數(shù)據(jù)進入Flink被處理的系統(tǒng)時間（Operator處...
-
Flink API1.Flink API介紹 Flink提供了不同的抽象級別以開發(fā)流式或者批處理應用程序 Stateful Stream Processing 最...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1897916/Snipaste_2020-07-08_14-13-21.png', '推薦專題《flink》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/dff2e0148a5f?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認gb2312'));){kind=link}