📝 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
- #3551 [server] prepareLakeTableSnapshot masks the real error on failure @fresh-borzoni
Pull Requests
- #3550 [server] Set table_id on prepareLakeTableSnapshot error response @fresh-borzoni
- #3549 [lake/hudi][docs] Add Hudi tiering service documentation @fhan688
- #3548 [flink]Newly discovered partition read from earliest rather than scan.startup.mode @loserwang1024
✅ 关闭 Issue/PR
已关闭 Issues
暂无
已合并 PRs
- #3542 [lake/iceberg] Fix listener leak in IcebergLakeCommitter @Guosmilesmile
- #3541 [lake/hudi] Add Hudi Flink union read primary key table IT @fhan688