📝 9 新 Issues
✅ 1 关闭
✨ 6 新 PRs
🎉 3 合并
🔥 核心要点
- 🎉 PR #3226 Website Redesign 已合并，改进了文档网站设计
- 🐛 PR #3271 修复了 COUNT(column) 聚合下推在可空列上的错误结果问题
- ✨ PR #3350 新增对 Flink offset lag 的支持
- ✨ PR #3346 实现了 Spark DSv2 的 SupportsPushDownLimit 接口
- 🚀 PR #3340 为 TabletServer 添加了磁盘使用率写保护机制
💬 Issue/PR 动态
Issue 讨论
Issue #3319 [FIP-37] Add bitmap infrastructure: BitmapUtils, RoaringBitmapSerializer, AbstractRbAggFunction
- @polyzos: 审查代码并提出了异常处理、注释及序列化逻辑的改进建议
- @Prajwal-banakar: 已根据审查意见修复代码风格、异常处理及测试覆盖
Issue #3299 [server] Add authorization to Replication Control RPCs (notifyLeaderAndIsr, updateMetadata, stopReplica, adjustIsr)
- @wuchong: 分析了测试失败根因，指出新增校验存在安全风险，建议限制 RPC 仅为内部会话
Issue #3304 [flink] currentFetchEventTimeLag is misleading when subscribing multiple partitions/buckets with uneven lag
- @zuston: 建议设计类似 Kafka 的机制来追踪 bucket 级别的 endOffset 并计算 lag
Issue #3340 [server] Add disk-usage write protection to TabletServer
- @swuferhong: 讨论了磁盘保护策略，认为 Writer-side fencing 是最小充分响应
Issue #2982 [test] Unstable test CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit
- @github-actions[bot]: 报告了 CI 测试失败信息
Issue #3227 [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1)
- @beryllw: 讨论了 Fluss 中表统计信息的准确性假设及实现依据
Issue #3226 [Docs] Website Redesign
- @wuchong: 推送了代码风格和显示问题的修复提交
PR Review
PR #3226 [Docs] Website Redesign
- @wuchong: 建议修正 Delta Join 图表的箭头方向与描述，并修复图片显示问题
- @fresh-borzoni: 建议标记计划中的引擎以避免混淆，并提出了多处文案改进建议
PR #3316 [lake/hudi] Introduce HudiBucketingFunction for bucket strategy
- @fhan688: 详细解释了 Hudi KeyEncoder 的实现对齐逻辑及测试覆盖情况
PR #3319 [FIP-37] Add bitmap infrastructure: BitmapUtils, RoaringBitmapSerializer, AbstractRbAggFunction
- @polyzos: 提出了关于异常类型、注释准确性、序列化优化及测试覆盖的改进建议
- @Prajwal-banakar: 已根据建议修复代码，优化了序列化逻辑并添加了测试
📝 新建 Issue/PR
Issues
- #3353 [server] Support altering table.auto-partition.enabled @fhan688
- #3351 [server] Support altering table.auto-partition.num-precreate @fhan688
- #3349 add support of offset lag @zuston
- #3348 [rebalance] Support rate‑limiting‑like effect by controlling number of partitions rebalanced at one time @fhan688
- #3344 [spark] Implement SupportsRuntimeV2Filtering @Yohahaha
- #3343 [spark] Implement SupportsReportPartitioning @Yohahaha
- #3342 [spark] Implement SupportsPushDownLimit @Yohahaha
- #3341 [spark] Umbrella issue to track spark dsv2 interface @Yohahaha
- #3338 [server] Add disk-usage write protection to TabletServer @swuferhong
Pull Requests
- #3352 [docs] remove the unused maputils rule @zuston
- #3350 [flink] support offset lag @zuston
- #3347 [docs]:Add Flink CDC integration doc under Flink @ThorneANN
- #3346 [spark] Implement SupportsPushDownLimit DSv2 interface @Yohahaha
- #3340 [server] Add disk-usage write protection to TabletServer @swuferhong
- #3339 [docs] Clarify auto partition retention alter support @luoyuxia
✅ 关闭 Issue/PR
已关闭 Issues
- #3270 [flink] COUNT(column) aggregate pushdown produces incorrect results for nullable columns @beryllw
已合并 PRs
- #3345 [hotfix] logo disappears from landing page when in dark mode @polyzos
- #3271 [flink] Fix COUNT(column) aggregate pushdown to reject nullable columns @beryllw
- #3226 [Docs] Website Redesign @polyzos