数据范围:本报告基于
apache/seatunnel仓库dev分支的合并提交记录,统计窗口为 2026-09-01 至 2026-09-30(UTC),覆盖完整自然月。
一、本月社区整体贡献数据
1.1 数据概览
| 指标 | 2026 年 9 月 |
|---|---|
| 合并提交数 | 260 |
| 活跃贡献者 | 48 |
| 日均提交数 | 8.7 |
| 新增连接器 | 24 |
| OptionRule 迁移 | 20 |
| Zeta 相关提交 | 42 |
解读:9 月日均提交数达 8.7 次,社区开发节奏紧凑。新增连接器数量达到 24 个,连接器生态扩张进入快车道。
1.2 提交类型分布
按 Commit Message 标签分类(每提交归入最优先类别,优先级:Feature > Fix/Bug/Hotfix > Improve > Doc/Docs > Test/E2E/CI/Benchmark > Chore/Chart/其他):
| 类别 | 提交数 | 占比 |
|---|---|---|
| Fix(缺陷修复) | 86 | 33.1% |
| Improve(增强优化) | 58 | 22.3% |
| Test(测试/CI/E2E/Benchmark) | 47 | 18.1% |
| Feature(新功能/新连接器) | 45 | 17.3% |
| Docs(文档) | 22 | 8.5% |
| Other(Chore/Chart 等) | 2 | 0.8% |
| 合计 | 260 | 100% |
解读:缺陷修复与增强优化合计占比 55.4%,说明社区持续投入系统稳定性打磨与能力迭代;新功能(含 24 个新连接器)占比 17.3%;测试与 CI 类提交占比 18.1%,质量保障投入保持高位。
二、核心贡献者及典型贡献案例
2.1 贡献者提交数排行(Top 15)
以下排名按 9 月提交数降序排列:
| 排名 | GitHub ID | 提交数 | 主要贡献方向 |
|---|---|---|---|
| 1 | goutamadwant | 52 | 新连接器、OptionRule 迁移、序列化修复、CI 改进 |
| 2 | zhangshenghang | 29 | CDC/JDBC 修复、Zeta 稳定性、Transform 修复 |
| 3 | DanielLeens | 26 | Zeta E2E 测试、CI 稳定化、JDBC XA 事务 |
| 4 | davidzollo | 25 | Zeta E2E 测试、HTTP 连接器、CI 安全 |
| 5 | SEPURI-SAI-KRISHNA | 19 | MQTT/RocketMQ 连接器测试、HashUtils 工具 |
| 6 | nzw921rx | 19 | Zeta 性能基准、REST 安全、构建修复 |
| 7 | Nikk8091 | 8 | OptionRule 迁移、连接器校验 |
| 8 | yigitcan-ozturk | 7 | OptionRule 迁移、连接器校验 |
| 9 | SEZ9 | 6 | Zeta REST 改进、CI 改进 |
| 10 | hutiefang76 | 5 | HugeGraph、CDC 修复、文档 |
| 11 | DanielCarter-stack | 5 | 连接器文档改进 |
| 12 | ClaireLytt | 4 | 新连接器(SMB/Ads 系列) |
| 13 | corgy-w | 4 | 连接器优化、Transform 修复 |
| 14 | CryoThrust | 4 | Kafka 序列化、Core 校验重构 |
| 15 | dybyte | 3 | CDC Schema 演进、WAL 优化 |
2.2 首次贡献者
本月共有多位贡献者在 SeaTunnel 仓库完成首次或早期提交,涵盖新连接器开发、OptionRule 迁移、文档改进等方向。以下为代表性首次贡献者:
| GitHub ID | 主要贡献 |
|---|---|
| ClaireLytt | SMB Source&Sink、Facebook/Google Ads、Zendesk Sink 等多个新连接器 |
| saloni-eng | Splunk Source、Linear HTTP Source 连接器 |
| CodeWithPravinMaske | Zeta GCS checkpoint/IMap 存储支持 |
| TianHengZhuang | Easysearch/Fake OptionRule 迁移 |
| 1328837476-hug | Firestore/Slack 声明式校验 |
| moneycat957 | Amazon DocumentDB Source |
| hyoj-dev | Aerospike OptionRule 迁移 |
| jjj-n | Neo4j OptionRule 迁移 |
| lce-mo | MySQL→HDFS 分区 Parquet 示例文档 |
| SatyamPandey-07 | 连接器文档改进 |
| smoggy666 | Druid Sink 声明式校验 |
| ZYZ666-RGB | Lance Sink 校验 |
| awesomesud347 | Zeta Web UI 性能优化 |
| ricky2129 | HadoopFileSystemProxy 修复 |
| surafel58 | Prometheus 重试机制 |
| inchang-ing | RAG 数据处理指南 |
| zeguilherme99 | Tablestore 校验 |
解读:首次贡献者中多人直接承担了新连接器开发(ClaireLytt 一人贡献 4 个新连接器)与 OptionRule 迁移等核心任务,表明社区新人上手效率与贡献质量均较高。
2.3 典型贡献案例
案例一:goutamadwant — 连接器生态扩张的核心力量
本月以 52 次提交 位居榜首,独立或主导完成了 12 个 新连接器的开发,覆盖支付、广告、云存储、消息队列、SaaS 等关键场景:
- 支付/金融:Stripe PaymentIntents Source(#11940)、PayPal Transaction Search Source(#12282)
- 广告平台:TikTok Ads Source(#12283)、Google Analytics 4 Source(#12280)
- 云存储:Google Cloud Storage File Source(#11967)& Sink(#12146)、Azure Queue Storage Source(#12006)、Azure Event Hubs Source(#12048)
- AI/向量:Deep Lake Sink(#11852)
- SaaS/通信:RFC 5424 Syslog Sink over TLS(#12279)、SNMPv2c SET Sink(#12011)、Salesforce Sink(#12245)
- 基础设施增强:Hive AWS Glue Data Catalog 支持(#11895)、Kafka/S3 Source 连通性 dry-run(#12167/#12242)、Zeta GCS checkpoint 存储(#12551)
此外还完成了 Prometheus、DynamoDB 等连接器的 OptionRule 迁移,以及 Avro/Protobuf 序列化层的多项兼容性修复。
案例二:zhangshenghang — CDC 与 Zeta 稳定性的中坚力量
本月贡献 29 次提交,聚焦 CDC(变更数据捕获)与 Zeta 引擎的稳定性:
- PostgreSQL CDC:数据库发现过滤(#11399)、表 ID 去重支持 HighGo(#12435)、committed-offset 恢复修复(#11864,合作)
- JDBC 系列:SapHana NCHAR 类型支持(#12158)、DB2 默认值读取(#12157)、XA 提交失败传播(#11569,合作)、where_condition 应用于 split 元数据(#12160)
- Zeta 稳定性:master failover 后固定槽位复用(#11458)、checkpoint barrier 计数器清理(#12260)、schema change checkpoint 去重(#12150)、connector jar 操作跳过 master-only 节点(#12023)
案例三:DanielLeens & davidzollo — Zeta E2E 测试体系建设
两人合计贡献 51 次提交,主导了 Zeta 引擎端到端(E2E)测试体系的大规模扩充:
- DanielLeens(26 次):覆盖 checkpoint restore(#12110/#12183/#12195)、master failover(#12184/#12197)、checkpoint-trigger 故障(#12199)、CheckpointMonitorService 启动竞态(#12200)、classloader 释放(#12143)等关键路径的 E2E 回归测试
- davidzollo(25 次):覆盖 deploy 幂等性(#12029)、source close 握手期间 failover(#12031)、sink checkpoint-cache 泄漏(#12095)、slot 释放(#12098)、背压场景(#12107)等场景
这批 E2E 测试为 Zeta 引擎的故障恢复与高可用能力提供了坚实的回归保障。
案例四:ClaireLytt — 高效的新连接器贡献者
作为首次或早期贡献者,本月独立交付了 4 个 新连接器:SMB Source&Sink(#12297)、Facebook Ads Source(#12275)、Zendesk Sink(#12253)、Google Ads Source(#12230),展现了极高的贡献效率。
三、重点社区项目进展复盘
3.1 连接器生态扩张(新增 24 个连接器)
本月新增连接器数量达到 24 个,覆盖支付金融、广告营销、云存储、数据库、AI 向量、SaaS 等多个领域:
| 类别 | 连接器 | 类型 | 贡献者 | PR |
|---|---|---|---|---|
| 支付/金融 | Stripe PaymentIntents Source | Source | goutamadwant | #11940 |
| 支付/金融 | PayPal Transaction Search Source | Source | goutamadwant | #12282 |
| 广告平台 | Google Ads Source | Source | ClaireLytt | #12230 |
| 广告平台 | Facebook Ads Source | Source | ClaireLytt | #12275 |
| 广告平台 | TikTok Ads Source | Source | goutamadwant | #12283 |
| 数据分析 | Google Analytics 4 Source | Source | goutamadwant | #12280 |
| 云存储 | Google Cloud Storage File Source | Source | goutamadwant | #11967 |
| 云存储 | Google Cloud Storage File Sink | Sink | goutamadwant | #12146 |
| 云存储 | Azure Queue Storage Source | Source | goutamadwant | #12006 |
| 云存储 | Azure Event Hubs Source | Source | goutamadwant | #12048 |
| 云数据库 | Amazon DocumentDB Source | Source | moneycat957 | #12046 |
| 消息队列 | OceanBase CDC Source | Source | davidzollo | #11060 |
| 实时数据库 | Firebase Realtime DB Source | Source | Kareemingit | #11637 |
| 实时数据库 | Firebase Sink | Sink | Kareemingit | #12232 |
| AI/向量 | Deep Lake Sink | Sink | goutamadwant | #11852 |
| AI/向量 | Mem0 Platform V3 ADD Sink | Sink | CryoThrust | #12233 |
| 网络管理 | SNMPv2c SET Sink | Sink | goutamadwant | #12011 |
| 日志/SIEM | Splunk Source | Source | saloni-eng | #12281 |
| 日志/SIEM | RFC 5424 Syslog Sink | Sink | goutamadwant | #12279 |
| SaaS/CRM | Salesforce Sink | Sink | goutamadwant | #12245 |
| SaaS/CRM | Zendesk Sink | Sink | ClaireLytt | #12253 |
| SaaS/项目 | Linear HTTP Source | Source | saloni-eng | #12270 |
| 电商 | Shopify Source | Source | GabrielBBaldez | #11028 |
| 文件共享 | SMB Source & Sink | Source+Sink | ClaireLytt | #12297 |
复盘:
- 广告与 SaaS 连接器爆发:本月新增了 Google/Facebook/TikTok 三大广告平台连接器,以及 Salesforce、Zendesk、Linear、Shopify 等 SaaS 连接器,标志着 SeaTunnel 在营销数据集成领域的能力大幅增强。
- 云存储生态完善:GCS Source/Sink 的补齐意味着 SeaTunnel 在主流公有云对象存储(AWS S3、阿里云 OSS、Google GCS)上的能力已基本对齐;Azure Queue Storage 与 Event Hubs 的加入拓展了 Azure 生态覆盖。
- AI 数据场景深化:Deep Lake 与 Mem0 两个向量/AI 存储连接器的引入,表明 SeaTunnel 正积极布局 AI 数据基础设施场景。
3.2 OptionRule 声明式校验迁移(20 条)
OptionRule 迁移是 SeaTunnel 连接器层的长期工程,目标是将各连接器分散的过程式配置校验统一到声明式 OptionRule 框架。本月完成 20 条 迁移:
| 连接器 | 迁移项 | 贡献者 | PR |
|---|---|---|---|
| Prometheus | batch.size 校验 | goutamadwant | #11738 |
| Amazon DynamoDB | max.retries 校验 | goutamadwant | #11821 |
| Aerospike | data.format 校验 | hyoj-dev | #12090 |
| HugeGraph | Sink 校验 | Nikk8091 | #12075 |
| Neo4j | 全量配置校验 | jjj-n | #12047 |
| SensorsData | 全量校验 | Nikk8091 | #12315 |
| FilterRowKind | Transform 校验 | goutamadwant | #11763 |
| S3 Redshift | 声明式校验 | yigitcan-ozturk | #12274 |
| BigQuery | 声明式校验 | yigitcan-ozturk | #12272 |
| Google Firestore | Sink 校验 | 1328837476-hug | #12278 |
| Druid | Sink 校验 | smoggy666 | #12250 |
| Lance | Sink 校验 | ZYZ666-RGB | #12222 |
| Amazon SQS | URL/region 校验 | xinnyuli | #12217 |
| Slack | 必填项校验 | 1328837476-hug | #12178 |
| DataHub | Sink 校验 | yigitcan-ozturk | #12174 |
| Sentry | DSN 校验 | yigitcan-ozturk | #12148 |
| Easysearch | Source/Sink 约束 | TianHengZhuang | #12414 |
| Fake | Source 约束 | TianHengZhuang | #12404 |
| RabbitMQ | queue_name 校验 | yigitcan-ozturk | #12519 |
| TDengine | 必填项校验 | yigitcan-ozturk | #12490 |
复盘:本月迁移覆盖了从数据库到 SaaS 的多样化连接器类型。多位首次贡献者(hyoj-dev、jjj-n、smoggy666、ZYZ666-RGB、TianHengZhuang)的参与表明该工程已具备良好的上手友好度。
3.3 Zeta 引擎可观测性与稳定性(42 次提交)
Zeta 作为 SeaTunnel 自研的分布式执行引擎,本月在 性能基准测试、E2E 测试覆盖、故障恢复修复 三条主线均有重要进展:
- 性能基准体系建设:
- Checkpoint 完成基准(#12026)、State Storage/Recovery 基准(#12044)、ProtoStuff 序列化基准(#12177)、Checkpoint 存储 retention-prune 验证(#12144)
- JMH 基准 CV/误差暴露(#12089)、CLI 基准结果跨版本对比(#12192)、基准 profiling 诊断(#12021)
- Zeta 基准指南与性能贡献指南文档(#12213/#12214/#12062)
- E2E 测试覆盖大幅扩充(详见 2.3 案例三):覆盖 checkpoint restore、master failover、classloader 释放、slot 管理、背压等场景
- 故障恢复修复:
- master failover 后固定槽位复用(#11458)
- checkpoint restore 并行度 >1 时 subtask state 重复映射修复(#12195)
- pending job 插入中断传播(#12052)
- WAL recovery 内存使用优化(#11494)
- CDC failover 后 runtime schema 恢复(#11503)
- REST API 加固:
- 配置文件大小上限(#12072)、错误信息改进(#12070)、各成员 REST 端口解析(#12298)
- Helm Chart 默认禁用未认证 Zeta REST API v1(#12513)
- Web UI 增强:Worker 资源快照展示(#12398)、任务详情页响应式优化(#12259)
3.4 CDC Schema 演进与核心引擎改进
| 方向 | 关键变更 | 贡献者 | PR |
|---|---|---|---|
| PostgreSQL CDC | 支持 ADD COLUMN Schema 演进 |
dybyte | #11922 |
| BigQuery | 支持 ADD COLUMN Schema 演进 |
dybyte | #11577 |
| MongoDB CDC | 支持 timestamp stop 模式 | goutamadwant | #11815 |
| CDC | 禁用 schema change 传播时保留 live schema | nielifeng | #12321 |
| CDC | snapshot 完成 watermark 重建 | zhangshenghang | #12162 |
| Flink | 同 timestamp schema restore 事件处理 | nzw921rx | #12306 |
| Kafka | 支持 Confluent-framed Avro 载荷 | CryoThrust | #12088 |
| RabbitMQ | 支持 Protobuf 格式 | DanielLeens | #12244 |
| Transform | 新增 Python Transform | davidzollo | #11390 |
| Transform | MOD 除数类型契约与溢出边界 | SEPURI-SAI-KRISHNA | #12182 |
| Core | HashUtils.bucketIndex 哈希分桶工具 | SEPURI-SAI-KRISHNA | #11987 |
| Core | 可复用配置校验结果 | CryoThrust | #12065 |
复盘:PostgreSQL 与 BigQuery CDC 的 ADD COLUMN Schema 演进支持是本月引擎层的重要里程碑,意味着 SeaTunnel 在 CDC 场景下对源端结构变更的适应性进一步增强;Kafka Confluent Avro 与 RabbitMQ Protobuf 的支持拓展了消息队列连接器的格式兼容性。
3.5 CI 稳定性与安全
本月在 Test/CI 类别下有多项 CI 稳定性与安全相关提交,主要方向:
- CI 安全加固:Docker 发布 action 固定 SHA(#12356)、SeaTunnel 公共团队用于 merge queue 绕过(#12229)、merge queue bypass actor 修复(#12219)
- CI 稳定性:MinIO 镜像切换至 quay.io 镜像(#12287/#12478)、S3 dry-run 测试使用 MinIO 镜像(#12302)、CI 测试时长 headroom 调整(#12374/#12445)
- CI 智能路由:仅检查变更的 markdown 文件死链(#12469)、engine/UDF/standalone 变更路由至对应测试(#12474)
- 测试报告:测试失败时上传报告并列出失败测试(#12470)、Docker 发布使用选定 tag(#12550)
四、9 月热门讨论 Issue
本月社区在 Issue 区围绕 Zeta 引擎性能优化、CDC 可观测性、连接器需求征集 等方向展开了深入讨论。以下为 9 月评论数最多的 5 个代表性 Issue:
| 排名 | Issue | 评论数 | 提出者 | 状态 |
|---|---|---|---|---|
| 1 | #10443 [Feature][Connector] Add connectors for these datasources | 39 | davidzollo | Open |
| 2 | #12058 [Improve][Zeta] Investigate and optimize checkpoint state-store latency variance | 35 | nzw921rx | Open |
| 3 | #12063 [Improve][Zeta] Investigate and improve job lifecycle growth benchmark stability | 33 | nzw921rx | Open |
| 4 | #12267 Got an error when performing CDC write operations using HighGo DB | 33 | 1362227089 | Open |
| 5 | #11364 [STIP-30][Feature][CDC] Unified CDC lag and progress observability model | 29 | goutamadwant | Open |
4.1 连接器需求征集(#10443,39 条评论)
由 davidzollo 于 2 月发起的连接器需求征集 Issue,在 9 月持续获得社区高度关注。社区成员在该 Issue 下提出了大量新数据源/目标端的需求建议,涵盖广告平台、SaaS 系统、向量数据库、云原生数据库等方向。本月新增的 24 个连接器中,多个与该 Issue 中征集的需求直接相关,体现了社区需求驱动的开发模式。
4.2 Zeta Checkpoint 状态存储延迟优化(#12058,35 条评论)
由 nzw921rx 于 9 月 3 日提出,聚焦 Zeta 引擎 checkpoint state-store 的延迟波动问题。讨论围绕 HDFS 写入同步、RequestFuture/WALWorkHandler 正确性、ProtoStuff 序列化等技术细节展开,已关联 PR #12081 进行修复。该 Issue 是本月 Zeta 性能优化方向的核心议题之一。
4.3 Zeta 任务生命周期基准测试稳定性(#12063,33 条评论)
与 #12058 同日提出,关注 Zeta job lifecycle growth 基准测试的稳定性问题。社区成员就基准测试的方差控制、JMH 配置、并发场景下的资源竞争等进行了深入讨论,关联 PR #12173 已提交修复方案。该 Issue 与 9 月建立的 Zeta 基准测试体系直接呼应。
4.4 HighGo 数据库 CDC 写入异常(#12267,33 条评论)
由用户 1362227089 于 9 月 11 日反馈的 HighGo 数据库 CDC 写入异常问题。讨论涉及 PostgreSQL CDC 的表发现、表 ID 去重、HighGo 数据库兼容性等细节,直接推动了 #12435(表 ID 去重支持 HighGo)和 #11399(数据库发现过滤)等修复 PR 的合并。
4.5 CDC 延迟与进度统一可观测性模型(#11364,29 条评论)
由 goutamadwant 发起的 STIP-30 设计提案,旨在为 CDC 连接器建立统一的延迟(lag)和进度(progress)可观测性模型。讨论涵盖指标定义、上报机制、与现有 metrics 体系的集成等架构层面的设计决策,是 CDC 方向的重要长期议题。
五、存在的问题与改进方向
5.1 社区协作
- 贡献者集中度较高:Top 6 贡献者合计提交 170 次,占全月 65.4%,社区贡献存在一定的头部集中现象。建议持续扩大"good first issue"范围,吸引更多长尾贡献者参与。
- 贡献者 ID 规范:部分贡献者的 git 提交未使用 GitHub
noreply邮箱,自动化统计需人工核实 GitHub ID。建议在贡献指南中明确推荐使用 GitHub noreply 邮箱配置 git。
5.2 工程质量
- OptionRule 迁移仍有存量:虽本月完成 20 条迁移,但仍有大量存量连接器未迁移。建议制定分批次迁移计划,优先处理配置项较多、校验逻辑复杂的连接器。
- CDC Schema 演进覆盖不全:目前仅 PostgreSQL 与 BigQuery 支持
ADD COLUMN,建议向 MySQL、Oracle、SQL Server 等其他 CDC 连接器推广,并支持DROP COLUMN、RENAME COLUMN等更多变更类型。 - Zeta 性能数据透明度:基准测试体系已建立,但基准结果尚未形成公开的性能报告或 Dashboard。建议将基准测试结果纳入 CI 产物或定期发布性能趋势报告。
5.3 数据采集
- 代码增删行统计缺失:由于仓库为
blob:nonepartial clone 且网络受限,git numstat无法正常返回。建议后续报告通过 GitHub API 按 PR 拉取 diff 统计,补全增删行维度数据。
附录:2026 年 9 月合并提交分类速查
A.1 Feature 类(45 条,部分重点)
| Short Hash | 贡献者 | 标题摘要 | PR |
|---|---|---|---|
| 12048 | goutamadwant | Add Azure Event Hubs source | #12048 |
| 12297 | ClaireLytt | Add SMB source&sink connector | #12297 |
| 11060 | davidzollo | Add OceanBase CDC source connector | #11060 |
| 12281 | saloni-eng | Add Splunk Source Connector | #12281 |
| 12282 | goutamadwant | Add PayPal Transaction Search source | #12282 |
| 12280 | goutamadwant | Add Google Analytics 4 report source | #12280 |
| 12279 | goutamadwant | Add RFC 5424 Syslog sink over TLS | #12279 |
| 12283 | goutamadwant | Add TikTok Ads reporting source | #12283 |
| 12245 | goutamadwant | Add Salesforce sink | #12245 |
| 12275 | ClaireLytt | Add Facebook Ads source connector | #12275 |
| 12270 | saloni-eng | Add Linear HTTP Source Connector | #12270 |
| 12253 | ClaireLytt | Add zendesk sink | #12253 |
| 12230 | ClaireLytt | Add Google Ads Source Connector | #12230 |
| 12011 | goutamadwant | Add SNMPv2c SET sink connector | #12011 |
| 12146 | goutamadwant | Add Google Cloud Storage file sink | #12146 |
| 12046 | moneycat957 | Add Amazon DocumentDB source connector | #12046 |
| 11028 | GabrielBBaldez | Add Shopify source connector | #11028 |
| 11967 | goutamadwant | Add Google Cloud Storage file source | #11967 |
| 11852 | goutamadwant | Add Deep Lake sink connector | #11852 |
| 11637 | Kareemingit | Add Firebase Realtime Database source | #11637 |
| 12006 | goutamadwant | Add Azure Queue Storage source | #12006 |
| 11940 | goutamadwant | Add Stripe PaymentIntents source | #11940 |
| 12232 | Kareemingit | Firebase sink connector | #12232 |
| 12233 | CryoThrust | Add Mem0 Platform V3 ADD sink | #12233 |
| 11922 | dybyte | Support PostgreSQL CDC ADD COLUMN schema evolution | #11922 |
| 11577 | dybyte | Support ADD COLUMN schema evolution for BigQuery | #11577 |
| 11390 | davidzollo | Add Python transform | #11390 |
| 12551 | CodeWithPravinMaske | Zeta Support GCS for checkpoint and IMap storage | #12551 |
| 12398 | goutamadwant | Zeta Show worker resource snapshots in Web UI | #12398 |
| 12026 | nzw921rx | Zeta Add checkpoint completion benchmark | #12026 |
| 12044 | nzw921rx | Zeta Add state storage and recovery benchmarks | #12044 |
A.2 Fix 类(86 条,部分重点)
| 贡献者 | 标题摘要 | PR |
|---|---|---|
| zhangshenghang | Filter Postgres CDC database discovery | #11399 |
| 1362227089 | Deduplicate table ids in PostgreSQL CDC table discovery | #12435 |
| zhang-arvin | Fix Postgres-CDC committed-offset recovery skipping rows | #11864 |
| zhangshenghang | JDBC SapHana NCHAR type support | #12158 |
| zhangshenghang | JDBC DB2 default values as strings | #12157 |
| DanielLeens | Propagate JDBC XA commit failures | #11569 |
| DanielLeens | Zeta checkpoint restore remap for parallelism > 1 | #12195 |
| zhangshenghang | Zeta reuse fixed slots after master failover | #11458 |
| zhangshenghang | Zeta clean empty checkpoint barrier counters | #12260 |
| zhangshenghang | Zeta ignore duplicate schema change checkpoint | #12150 |
| CryoThrust | Zeta propagate interrupted pending job insertion | #12052 |
| SEZ9 | Zeta resolve each member's bound REST HTTP port | #12298 |
| nielifeng | CDC restore runtime schema from checkpoint after failover | #11503 |
| goutamadwant | Fix Kudu client deadlock in Flink JobManager on JDK 11 | #12480 |
| goutamadwant | Stop bundling debezium-core in OceanBase CDC jar | #12477 |
| zhangshenghang | Support FTP append data mode | #11554 |
| zhangshenghang | Fix JDBC batch data error masking | #11474 |
| zhangshenghang | Propagate HTTP sink write failures | #12312 |
| corgy-w | Make rename transform case conversion locale independent | #11994 |
| zhangshenghang | Preserve exact binary value when CASTing floats to DECIMAL | #11523 |
A.3 Improve 类(58 条,OptionRule 迁移为主)
OptionRule 迁移详见 §3.2(20 条)。其他重要 Improve:
| 贡献者 | 标题摘要 | PR |
|---|---|---|
| nzw921rx | Zeta reduce lock contention in ProtoStuff schema lookup | #12176 |
| dybyte | Zeta optimize WAL recovery memory usage | #11494 |
| awesomesud347 | Zeta apply finished-jobs page before per-job metrics | #12130 |
| nzw921rx | Zeta make job detail overview responsive | #12259 |
| CryoThrust | Core add reusable config validation result | #12065 |
| SEPURI-SAI-KRISHNA | Common add HashUtils.bucketIndex | #11987 |
| goutamadwant | Prometheus retry retryable remote-write failures | #11974 |
| DanielLeens | Allow committers to bypass the merge queue | #12198 |
A.4 Test / Docs / Other 类(71 条)
- Test(47 条):以 Zeta E2E 测试扩充为主(详见 §2.3 案例三),涵盖 checkpoint restore、master failover、classloader 释放、slot 管理、背压等场景。
- Docs(22 条):涵盖连接器文档批量改进(DanielCarter-stack 贡献 5 条,覆盖 JDBC/File/SFTP/SqlServer-CDC/Opengauss-CDC/Aerospike/Feishu/MySQL/GraphQL/Prometheus/InfluxDB/Greenplum/MQTT/Datahub/Socket/Web3j/ActiveMQ/IoTDB/Kafka/Maxcompute/OceanBase/Oracle 等)、Zeta 基准指南、RAG 数据处理指南等。
- Other(2 条):Chore 刷新活跃协作者(#12532)、Helm Chart 禁用未认证 Zeta REST API(#12513)。
报告生成说明:本报告所有数据均基于
apache/seatunnel仓库dev分支2026-09-01至2026-09-30的合并提交统计生成(共 260 次提交、48 位贡献者)。贡献者 ID 均已通过 GitHub PR 页面核实。如有数据疑问或补充,请联系 SeaTunnel 社区 PMC。