發(fā)簡(jiǎn)信
IP屬地：北京
-
Flink Job 調(diào)度[toc] 介紹 Flink 是如何調(diào)度 Job，以及如何在 JobManager 上維護(hù)并跟蹤 Job 狀態(tài)。 調(diào)度 Flink 通過(guò)任務(wù)槽（...
-
Flink Checkpoint 和 Large State 調(diào)優(yōu)Overview 為了使 Flink 應(yīng)用程序能夠可靠地大規(guī)模運(yùn)行，必須滿足兩個(gè)條件： 應(yīng)用程序需要能夠可靠地獲取 Checkpoint 在發(fā)生...
-
Flink State 和 Fault Tolerance（四）
State Snapshot 定義 Snapshot – 是 Flink 作業(yè)狀態(tài)全局一致鏡像的通用術(shù)語(yǔ)?？煺瞻ㄖ赶蛎總€(gè)數(shù)據(jù)源的指針（例如，到...
-
Flink State 和 Fault Tolerance（三）
[toc] Savepoint Savepoint 和 Checkpoint 的區(qū)別 Savepoint 是命令觸發(fā)的 Checkpoint，對(duì)...
-
Flink Side Outputs
Side Output 功能從 Flink 1.3.0 版本開(kāi)始提供，F(xiàn)LINK-4460[https://issues.apache.org/...
-
Flink State 和 Fault Tolerance（二）Checkpoint Flink 中的 State 在上一篇中介紹過(guò)，F(xiàn)link 中的每個(gè)方法或算子都能夠是有狀態(tài)的，為了使 State 容錯(cuò)，...
-
Flink State 和 Fault Tolerance（一）
Overview 有狀態(tài)函數(shù)（Stateful function）和算子（Operator）在處理獨(dú)立的數(shù)據(jù)或事件時(shí)存儲(chǔ)數(shù)據(jù)，使得狀態(tài)（Stat...
-
Flink EventTime 和 Watermark（1.13）時(shí)間概念 時(shí)間在流式計(jì)算中起很重要的作用，F(xiàn)link 提供了3種時(shí)間模型：EventTime、ProcessingTime、IngestionT...
-
Flink User-defined Source & Sink主要引用官方文檔 https://ci.apache.org/projects/flink/flink-docs-release-1.13/do...