[toc] 介紹 Flink 是如何調(diào)度 Job，以及如何在 JobManager 上維護(hù)并跟蹤 Job 狀態(tài)。 調(diào)度 Flink 通過任務(wù)槽（...
投稿
收錄了76篇文章 · 88人關(guān)注
-
Flink Job 調(diào)度 -
Flink Checkpoint 和 Large State 調(diào)優(yōu)Overview 為了使 Flink 應(yīng)用程序能夠可靠地大規(guī)模運(yùn)行，必須滿足兩個條件： 應(yīng)用程序需要能夠可靠地獲取 Checkpoint 在發(fā)生...
-
Flink State 和 Fault Tolerance（四）
State Snapshot 定義 Snapshot – 是 Flink 作業(yè)狀態(tài)全局一致鏡像的通用術(shù)語?？煺瞻ㄖ赶蛎總€數(shù)據(jù)源的指針（例如，到...
-
Flink State 和 Fault Tolerance（三）
[toc] Savepoint Savepoint 和 Checkpoint 的區(qū)別 Savepoint 是命令觸發(fā)的 Checkpoint，對...
-
Flink SQL Connector（一）- Format & Kafka
Format Flink 提供了一套與表連接器（table connector）一起使用的表格式（table format）。表格式是一種存儲格...
-
Flink Metrics主要引用官方文檔 https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh...
-
Flink Side Outputs
Side Output 功能從 Flink 1.3.0 版本開始提供，F(xiàn)LINK-4460[https://issues.apache.org/...
-
Flink State 和 Fault Tolerance（二）Checkpoint Flink 中的 State 在上一篇中介紹過，F(xiàn)link 中的每個方法或算子都能夠是有狀態(tài)的，為了使 State 容錯，...
-
Flink State 和 Fault Tolerance（一）
Overview 有狀態(tài)函數(shù)（Stateful function）和算子（Operator）在處理獨(dú)立的數(shù)據(jù)或事件時存儲數(shù)據(jù)，使得狀態(tài)（Stat...
-
Flink EventTime 和 Watermark（1.13）時間概念 時間在流式計(jì)算中起很重要的作用，F(xiàn)link 提供了3種時間模型：EventTime、ProcessingTime、IngestionT...
{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/593207/WechatIMG1.jpeg', '推薦專題《Spark & Flink》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/ddc9e4da34c2?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}