📝 1 新 Issues
✅ 3 关闭
✨ 4 新 PRs
🎉 6 合并
🔥 核心要点
- 🎉 PR #3355 修复 Flink log-only source 恢复模式问题，保留恢复状态
- 🎉 PR #3325 修复 DefaultRowMerger 全 schema 部分写入处理逻辑
- 🎉 PR #3194 优化 RemoteLogManifest 按 startOffset 排序
- 🐛 PR #3312 修复防止删除默认数据库导致 catalog 打开失败的问题
- ✨ PR #3398 新增 bitmap 聚合函数 rb_build_agg, rb_or_agg, rb_and_agg
💬 Issue/PR 动态
Issue 讨论
Issue #2917 [server] Add retract support for Aggregation Merge Engine
Issue #3299 [server] Add authorization to Replication Control RPCs (notifyLeaderAndIsr, updateMetadata, stopReplica, adjustIsr)
- @vaibhavk1992: 通知 @wuchong 已修复测试用例，请帮忙审查
Issue #3346 [spark] Implement SupportsPushDownLimit DSv2 interface
- @Yohahaha: 单元测试失败，原因是 #3397 导致的问题
Issue #3350 [flink] support offset lag
- @luoyuxia: 提醒 @loserwang1024 关注此 PR
Issue #3355 [flink] Preserve log-only source restore mode
- @luoyuxia: 通知将合并此 PR，如有其他意见可留言
Issue #3395 [lake/hudi] Introduce Hudi LakeCatalog to create table
- @fhan688: 所有测试已通过，请 @XuQianJin-Stars 帮忙审查
PR Review
PR #3325 [kv] Treat full-schema partial writes as full row for DefaultRowMerger
PR #3350 [flink] support offset lag
- @Copilot: 建议移除 recordLogEndOffset 的更新，使用真实的 high-watermark/listOffsets 结果更新 log end offset，避免低估 recordsLag
- @Copilot: 指出 recordsLag() 在未初始化时返回 0 会误导，建议返回 UNINITIALIZED 或暴露明确的未知状态
📝 新建 Issue/PR
Issues
- #3394 [test] Unstable test after DefaultAuthorizerTest @gyang94
Pull Requests
- #3398 [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog @Prajwal-banakar
- #3397 [spark] Split non-partition and partition predicates from pushPredicates to limit pushdown @Yohahaha
- #3396 [lake] Fix DvTableReadableSnapshotRetriever scanning wrong snapshot @luoyuxia
- #3395 [lake/hudi] Introduce Hudi LakeCatalog to create table @fhan688
✅ 关闭 Issue/PR
已关闭 Issues
- #3354 [flink] Avoid initializing lake snapshot splits after log-only source restore @luoyuxia
- #3311 [server] Prevent deletion of default database to avoid catalog open failure @gyang94
- #2759 [workflow/doc] How to host a community call as a contributor @MehulBatra
已合并 PRs
- #3355 [flink] Preserve log-only source restore mode @luoyuxia
- #3325 [kv] Treat full-schema partial writes as full row for DefaultRowMerger @zuston
- #3312 [server] fix: prevent delete default database @gyang94
- #3194 [server] make RemoteLogManifest sorted with startOffset @zuston
- #2792 [log] Output the leader server id and related table ids on fetching log failure @zuston
- #2760 [workflow/doc] how to host community call steps @MehulBatra