SeaTunnel 基准测试设计与实践

从一组真实结果出发,解释 SeaTunnelRow 微基准和单节点 Zeta Pipeline 基准的测量边界、指标含义、实现方法与理论依据。

2026 年 8 月 10 日 · 4 min · Niu Zhiwei

从 Java 微基准到流处理系统:三篇性能评估论文精读与 JMH 实战

沿着“测量对象、实验单位、重复预算、结果解释”四个问题精读三篇性能评估论文,再从源码层解释 JMH 的生成代码、Fork、Warmup、Measurement 与结果聚合,并给出四个可落地的微基准场景。

2026 年 7 月 31 日 · 11 min · Niu Zhiwei

Apache Flink 状态管理深度解析:从 Barrier 到端到端 Exactly-Once

以一个双输入聚合任务贯穿 Flink 状态管理论文:逐记录推演 Barrier Alignment、异步增量快照、故障恢复、事务 Sink、扩缩容,并区分 2017 年论文与 Flink 2.3 的实现边界。

2026 年 7 月 16 日 · 11 min · Niu Zhiwei

SeaTunnel 引擎进阶之路:从 JDBC 定时 Flush 到 Engine-Level FlushSignal

从 JDBC Sink 的 batch_interval_ms 定时 flush 问题出发,理解为什么 FlushSignal 应该成为 SeaTunnel Zeta 的引擎层能力。

2026 年 7 月 10 日 · 4 min · Niu Zhiwei

SeaTunnel 提交一个任务都经过了什么?

从 SubmitJobServlet 到 TaskExecutionService,梳理 SeaTunnel submitJob 的任务提交、调度、资源申请与 TaskGroup 部署主链路。

2026 年 7 月 7 日 · 4 min · Niu Zhiwei

我的个人博客第一版上线

第一版博客上线:后续会重点沉淀 Java、Go、大数据与 AI 工程实践。

2026 年 7 月 7 日 · 1 min · Niu Zhiwei