發(fā)簡信
IP屬地：北京
-
Flink Job 調(diào)度[toc] 介紹 Flink 是如何調(diào)度 Job，以及如何在 JobManager 上維護并跟蹤 Job 狀態(tài)。 調(diào)度 Flink 通過任務(wù)槽（...
-
Flink Checkpoint 和 Large State 調(diào)優(yōu)Overview 為了使 Flink 應(yīng)用程序能夠可靠地大規(guī)模運行，必須滿足兩個條件： 應(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 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）在處理獨立的數(shù)據(jù)或事件時存儲數(shù)據(jù)，使得狀態(tài)（Stat...
-
Flink EventTime 和 Watermark（1.13）時間概念 時間在流式計算中起很重要的作用，F(xiàn)link 提供了3種時間模型：EventTime、ProcessingTime、IngestionT...
-
Flink User-defined Source & Sink主要引用官方文檔 https://ci.apache.org/projects/flink/flink-docs-release-1.13/do...