🌊 Fluss 每日动态

📅 2026-06-30

🔗 apache/fluss

📝 1 新 Issues
✅ 0 关闭
✨ 3 新 PRs
🎉 2 合并

🔥 核心要点

⚠️ 重点关注

✅ 今日无重大问题

💬 Issue/PR 动态

Issue 讨论

Issue #3492 [FIP-37] Add bitmap scalar functions and register via FlussCatalog

  • @Prajwal-banakar: 请求维护者审核该 PR

Issue #3498 [server] Support limiting rebalance buckets per round

  • @fhan688: 请求 XuQianJin-Stars 协助审核
  • @luoyuxia: 抄送 swuferhong 参与审核

Issue #3500 [lake] Fix union read duplicating rows for non-String partition columns

  • @luoyuxia: 询问该 PR 的进度
  • @bryndenZh: 已根据建议更新代码,统一分区值格式化逻辑并优化性能

Issue #3540 [fs] Support AWS S3 credentials provider mode

  • @litiliu: 请求 fresh-borzoni 抽空审核

Issue #3542 [lake/iceberg] Fix listener leak in IcebergLakeCommitter

  • @Guosmilesmile: 感谢 luoyuxia 的审核

Issue #3543 [flink] scan.startup.mode=latest can skip rows written to a new partition before partition discovery

  • @loserwang1024: 表示已修复问题,请求审核

Issue #3548 [flink]Newly discovered partition read from earliest rather than scan.startup.mode

  • @loserwang1024: 抄送相关人员进行审核

PR Review

PR #3424 [docs] add docs to integrate Fluss + Iceberg via Flink with AWS Glue and Hive

  • @fresh-borzoni: 讨论 S3 凭证配置问题,计划添加修复并请求在 ECS 上测试

PR #3431 [server] Fix NPE when processing table registration change

  • @raoluSmile: 恢复了保护逻辑并增加了缺失表信息的回归测试

PR #3542 [lake/iceberg] Fix listener leak in IcebergLakeCommitter

  • @luoyuxia: 建议移除简单的测试用例,因为现有测试已覆盖
  • @Guosmilesmile: 同意移除测试类

PR #3548 [flink]Newly discovered partition read from earliest rather than scan.startup.mode

  • @leonardBang: 指出按 TableBucket 存储可能导致数据丢失,建议用 splitId;指出 V2 状态迁移默认值可能引发问题

📝 新建 Issue/PR

Issues

Pull Requests

✅ 关闭 Issue/PR

已关闭 Issues

暂无

已合并 PRs