📝 3 新 Issues
✅ 2 关闭
✨ 3 新 PRs
🎉 4 合并
🔥 核心要点
- 🎉 PR #3398 合并 Bitmap 聚合函数 (rb_build_agg, rb_or_agg, rb_and_agg)，实现 FIP-37
- 🎉 PR #3432 合并 Flink DataStream API 的 union read 支持功能
- 🐛 PR #3427 合并修复 failover 后 row count 错误问题，保持 flushedLogOffset 单调性
- 🎉 PR #3425 合并限制 SASL JAAS config 仅用于 PlainLoginModule 的安全改进
- ✨ PR #3456 新增 Hudi source split planner，推进湖仓一体化
💬 Issue/PR 动态
Issue 讨论
Issue #3398 [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog
- @platinumhamburg: 感谢贡献，同意当前实现方式，预期未来新增函数数量有限，当前方案可接受
- @polyzos: 推送了一些小改进，CI通过后即可合并，感谢出色的工作
- @Prajwal-banakar: 感谢审查和指导，对修改满意，这是一次很棒的学习经历
Issue #3432 [flink] Add union read support to datastream
- @polyzos: 已开启 #3452 来覆盖 partition pruning 支持的需求
Issue #3435 [Feature] Support implicit/hidden partitions for Fluss tables
- @litiliu: 分享了设计文档草稿链接，期待反馈和建议
- @zerolbsony: 感谢分享文档，稍后会查阅，有问题会联系
PR Review
PR #3174 [server] Add ReplicaCleanupManager to throttle drops in coordinator queue
- @wuchong: 建议将 replicaCleanupManager 通过构造函数注入设为 final，避免数据竞争；resumeAction 设计容易破坏并发安全
PR #3427 [server] Keep flushedLogOffset monotonic to fix row count after failover
- @platinumhamburg: 同意保持当前实现方式不变
PR #3453 [server] Support altering auto partition enabled option
- @Copilot: 建议将过期任务日志降为 DEBUG；toString() 中的标签命名应与代码库保持一致
PR #3456 [lake/hudi] Introduce Hudi source split planner
- @Copilot: partition 值提取可能产生大小/顺序不匹配；bucket-aware 默认值可能影响旧表；fileId 解析失败应优雅降级
📝 新建 Issue/PR
Issues
- #3455 [server] complete delayed fetch operations after produce to reduce fetch latency @gyang94
- #3454 Backpressure on KV Operations Instead of Cluster-Wide Stalling @platinumhamburg
- #3452 [Flink] Add support for partition pruning to the Datastream API @polyzos
Pull Requests
- #3456 [lake/hudi] Introduce Hudi source split planner @fhan688
- #3453 [server] Support altering auto partition enabled option @fhan688
- #3450 [test] Fix ComponentClassLoaderTest tmpdir path handling @litiliu
✅ 关闭 Issue/PR
已关闭 Issues
- #3422 Restrict the use of client.security.sasl.jaas.config to PlainLoginModule exclusively. @loserwang1024
- #3386 [test] Unstable test FlussAdminITCase.testGetTableStatsForPrimaryKeyTableWithFailover @app/github-actions
已合并 PRs
- #3432 [flink] Add union read support to datastream @polyzos
- #3427 [server] Keep flushedLogOffset monotonic to fix row count after failover @wattt3
- #3425 [client] Restrict the use of client.security.sasl.jaas.config to PlainLoginModule exclusively. @loserwang1024
- #3398 [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog @Prajwal-banakar