[toc] 介紹 Flink 是如何調(diào)度 Job,以及如何在 JobManager 上維護(hù)并跟蹤 Job 狀態(tài)。 調(diào)度 Flink 通過任務(wù)槽(...
投稿
[toc] 介紹 Flink 是如何調(diào)度 Job,以及如何在 JobManager 上維護(hù)并跟蹤 Job 狀態(tài)。 調(diào)度 Flink 通過任務(wù)槽(...
Overview 為了使 Flink 應(yīng)用程序能夠可靠地大規(guī)模運(yùn)行,必須滿足兩個條件: 應(yīng)用程序需要能夠可靠地獲取 Checkpoint 在發(fā)生...
State Snapshot 定義 Snapshot – 是 Flink 作業(yè)狀態(tài)全局一致鏡像的通用術(shù)語??煺瞻ㄖ赶蛎總€數(shù)據(jù)源的指針(例如,到...
[toc] Savepoint Savepoint 和 Checkpoint 的區(qū)別 Savepoint 是命令觸發(fā)的 Checkpoint,對...
Format Flink 提供了一套與表連接器(table connector)一起使用的表格式(table format)。表格式是一種存儲格...
主要引用官方文檔 https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh...
Side Output 功能從 Flink 1.3.0 版本開始提供,F(xiàn)LINK-4460[https://issues.apache.org/...
Checkpoint Flink 中的 State 在上一篇中介紹過,F(xiàn)link 中的每個方法或算子都能夠是有狀態(tài)的,為了使 State 容錯,...
Overview 有狀態(tài)函數(shù)(Stateful function)和算子(Operator)在處理獨(dú)立的數(shù)據(jù)或事件時存儲數(shù)據(jù),使得狀態(tài)(Stat...
時間概念 時間在流式計(jì)算中起很重要的作用,F(xiàn)link 提供了3種時間模型:EventTime、ProcessingTime、IngestionT...