📝 4 新 Issues
✅ 3 关闭
✨ 5 新 PRs
🎉 5 合并
💬 Issue/PR 动态
Issue 讨论
Issue #2881 [lake/iceberg] Support snapshot expiration for lake tables
- @vamossagar12: 实现 Iceberg 快照过期配置选项，通过提交次数和时间间隔双重阈值控制过期频率
Issue #3232 [server] Add request queue size metric per processor
- @zuston: 感谢 @fresh-borzoni 的贡献
Issue #3144 Batch reads on ``/`` fail with coordinator NPE instead of a clear unsupported error
- @QuakeWang: 主动请求分配该任务，表示愿意处理此问题
Issue #3397 [spark] Split non-partition and partition predicates from pushPredicates to limit pushdown
- @Yohahaha: 请求维护者审查 Spark 相关的谓词下推优化 PR
Issue #3398 [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog
- @Prajwal-banakar: 请求 @polyzos 和 @wuchong 帮助审查位图聚合函数 PR
Issue #3401 [FIP-40] merge fluss-rust
- @fresh-borzoni: 请求 @wuchong 和 @luoyuxia 审查 Rust 仓库合并提案
Issue #3403 [flink-action][server][client] add orphan files cleanup action for remote storage
- @sd4324530: 建议参考 Paimon 实现基于 Flink procedures 的孤立文件清理调用方式
PR Review
PR #3242 [client] Fix tiering hang on first_row merge engine empty batches
- @luoyuxia: 提出多项代码改进建议：变量命名优化、测试方法合并、逻辑简化等
PR #3390 [client] Fix stale metadata on readOnlyGateway by adding RetryableGatewayClientProxy
- @fresh-borzoni: 详细审查重试机制：建议添加退避策略、共享刷新请求、配置项化等优化
PR #2747 [client] Abort write batch if table id changes.
- @fresh-borzoni: 指出锁内调用外部方法的活性问题，建议批量处理过期批次
- @loserwang1024: 感谢审查建议，已根据反馈修改代码
PR #3383 [Flink] Kvscan flink integration
- @binary-signal: 完善文档说明：服务端 KV 扫描配置、有界读取行为、重启扫描机制等
📝 新建 Issue/PR
Issues
- #3407 [rust] Merge fluss-rust repo into fluss @fresh-borzoni
- #3405 [client] Initialize lake comparator when log scan is already finished @luoyuxia
- #3403 [flink-action][server][client] add orphan files cleanup action for remote storage @platinumhamburg
- #3399 [server] Support Cluster Health API for safe rolling upgrades @swuferhong
Pull Requests
- #3408 [website] Add Security Updates table to security page @wuchong
- #3404 [flink-action][server][client] add orphan files cleanup action for remote storage @platinumhamburg
- #3402 [flink] Fail fast on batch virtual log table reads @QuakeWang
- #3401 [FIP-40] merge fluss-rust @fresh-borzoni
- #3400 [server] Add Cluster Health API implementation @swuferhong priority=blocker
✅ 关闭 Issue/PR
已关闭 Issues
- #3405 [client] Initialize lake comparator when log scan is already finished @luoyuxia
- #3091 [server] RemoteLogFetcher optimize to async downloading @swuferhong
- #2686 [File system] Add Tencent Cloud COS integration @XuQianJin-Stars
已合并 PRs
- #3406 [client] Initialize lake comparator before merge read @luoyuxia
- #3380 org-names for Apache fluss (incubating) team @MehulBatra
- #3232 [server] Add request queue size metric per processor @zuston
- #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery @Kaixuan-Duan
- #2836 [FLUSS-2686] Add COS filesystem support @XuQianJin-Stars