-
甘特图怎么制作更方便？甘特图制作方法" title="甘特图怎么制作更方便？甘特图制作方法" width="200" height="150">
-
OKR的实施标准步骤是什么？成功实施落地OKR的要点" title="OKR的实施标准步骤是什么？成功实施落地OKR的要点" width="200" height="150">
-
Apache Flink 进阶（三）：Checkpoint 原理解析与应用实践
简介： 大家好，今天我将跟大家分享一下 Flink 里面的 Checkpoint，共分为四个部分。 Checkpoint 是从 source 触发到下游所有节点完成的一次全局操作。下图可以有一个对 C...
-
Apache Flink 进阶（四）：Flink on Yarn/K8s 原理剖析及实践
image.png 用户通过 DataStream API、DataSet API、SQL 和 Table API 编写 Flink 任务，它会生成一个JobGraph。JobGraph 是由 sou...
-
Flink状态管理与Checkpoint实战——模拟电商订单计算过程中宕机的场景，探索宕机恢复时如何精准继续计算订单
Flink的状态与容错是这个框架很核心的知识点。其中一致检查点也就是Checkpoints也是Flink故障恢复机制的核心，这篇文章将详细介绍Flink的状态管理和Checkpoints的概念以及在生...
-
Flink知识学习（9）
在流处理引擎之上，Flink 有以下机制： 检查点机制和状态机制：用于实现容错、有状态的处理； 水印机制：用于实现事件时钟； 窗口和触发器：用于限制计算范围，并定义呈现结果的时间。 在同一个流处理引擎...
-
05_说说Flink架构中的角色和作用？
image.png JobManager： 类似于经理 JobManager是Flink系统的协调者，它负责接收Flink Job，调度组成Job的多个Task的执行。同时，JobManager还负责...
-
Flink知识学习（20）
在启动 Checkpoint 机制时，状态会随着 Checkpoint 而持久化，以防止数据丢失，保障恢复时的一致性。状态内部的存储格式、状态在 Checkpoint 时如何持久化以及持久化在哪里，均...
