2025年12月30日
Flink源码阅读：Checkpoint机制（下）
摘要： Flink源码阅读：Checkpoint机制（下） 书接上回，前文我们梳理的 Checkpoint 机制的源码，但是对于如何写入状态数据并没有深入了解。今天就一起来梳理一下这部分代码。 阅读全文
posted @ 2025-12-30 20:13 Jackeyzhe 阅读(594) 评论(0) 推荐(0)
2025年12月25日
Flink源码阅读：Checkpoint机制（上）
摘要： Flink源码阅读：Checkpoint机制（上） 前文我们梳理了 Flink 状态管理相关的源码，我们知道，状态是要与 Checkpoint 配合使用的。因此，本文我们就一起来看一下 Checkpoint 相关的源码。 阅读全文
posted @ 2025-12-25 22:33 Jackeyzhe 阅读(537) 评论(0) 推荐(0)
2025年12月23日
Flink源码阅读：状态管理
摘要： Flink源码阅读：状态管理 前面我们介绍了 Flink 状态的分类和应用。今天从源码层面再看一下 Flink 是如何管理状态的。 阅读全文
posted @ 2025-12-23 21:44 Jackeyzhe 阅读(534) 评论(0) 推荐(0)
2025年12月22日
Flink源码阅读：集群启动
摘要： Flink源码阅读：集群启动 前文中，我们已经了解了 Flink 的三种执行图是怎么生成的。今天继续看一下 Flink 集群是如何启动的。 阅读全文
posted @ 2025-12-22 22:44 Jackeyzhe 阅读(672) 评论(0) 推荐(0)
2025年12月21日
Flink源码阅读：如何生成ExecutionGraph
摘要： Flink源码阅读：如何生成ExecutionGraph 今天我们一起来了解 Flink 最后一种执行图，ExecutionGraph 的执行过程。 阅读全文
posted @ 2025-12-21 22:29 Jackeyzhe 阅读(575) 评论(0) 推荐(0)
2025年12月20日
Flink源码阅读：如何生成JobGraph
摘要： Flink源码阅读：如何生成JobGraph 前文我们介绍了 Flink 的四种执行图，并且通过源码了解了 Flink 的 StreamGraph 是怎么生成的，本文我们就一起来看下 Flink 的另一种执行图——JobGraph 是如何生成的。 阅读全文
posted @ 2025-12-20 21:57 Jackeyzhe 阅读(624) 评论(0) 推荐(0)
2025年12月17日
Flink源码阅读：如何生成StreamGraph
摘要： Flink源码阅读：如何生成StreamGraph Flink 中有四种执行图，分别是 StreamGraph、JobGraph、ExecutionGraph 和 Physical Graph。今天我们来看下我们编写的 Flink 程序代码是如何生成 StreamGraph 的。 阅读全文
posted @ 2025-12-17 19:24 Jackeyzhe 阅读(597) 评论(0) 推荐(0)
2025年12月16日
Flink学习笔记：反压
摘要： Flink学习笔记：反压 今天来聊在 Flink 运维过程中比较常见的一个问题：反压。 阅读全文
posted @ 2025-12-16 20:51 Jackeyzhe 阅读(596) 评论(0) 推荐(0)
2025年12月15日
Flink学习笔记：状态后端
摘要： Flink学习笔记：状态后端 我们继续来聊 Flink 容错相关的内容。前面在介绍 Checkpoint 和 Savepoint 时提到了 State 的稳定存储，那究竟如何存储以及存储在什么地方呢？相信通过读完本文之后，你会有答案。 阅读全文
posted @ 2025-12-15 22:49 Jackeyzhe 阅读(593) 评论(0) 推荐(1)
2025年12月14日
Flink学习笔记：如何做容错
摘要： Flink学习笔记：如何做容错 现在我们已经了解了 Flink 的状态如何定义和使用，那 Flink 是如何做容错的呢？今天我们一起来了解一下。 阅读全文
posted @ 2025-12-14 20:27 Jackeyzhe 阅读(523) 评论(0) 推荐(0)