📝 9 新 Issues
✅ 7 关闭
✨ 4 新 PRs
🎉 12 合并
🔥 核心要点
- 🎉 PR #3067 支持默认 AWS 凭证链进行 S3 委派，解决 IRSA/IAM 角色使用问题
- 🎉 PR #2855 KV 表恢复期间支持从远程存储下载 CDC 日志段
- 🚀 PR #3026 使用 bump-pointer ChunkedAllocationManager 替代 Netty PooledByteBufAllocator 优化 Arrow 内存分配
- 🎉 PR #3076 为 lake tiering 表添加 pendingTime 和 freshness 指标
- 🐛 PR #2997 修复 client.fs.* 配置前缀未正确传递给文件系统插件的 bug
💬 Issue/PR 动态
Issue 讨论
Issue #3073 add document for how contributors can be granted more rights such as commit access or decision power is clearly documented
- @luoyuxia: 感谢贡献，已将任务分配给你
- @matrixsparse: 感谢！将开始处理并尽快提交 PR
Issue #2836 [FLUSS-2686] Add COS filesystem support
- @XuQianJin-Stars: 详细回应了 STS 实现、REGION 常量和 Endpoint 一致性三个问题，已更新代码和测试覆盖
Issue #3067 [filesystem] Support default AWS credential chain for S3 delegation
- @fresh-borzoni: 添加了 IRSA/实例配置文档示例，建议回port到 0.9 版本以支持 AWS/EKS 部署
- @affo: 感谢添加文档说明，已批准，需要 committer 合并
Issue #2997 [filesystem][bug] Fix client.fs.* config prefix not stripped before passing to…
- @fresh-borzoni: 请求 reviewer 审阅 PR
- @morazow: 建议更新 Javadoc、扩展测试用例覆盖新配置键
- @polyzos: 将此内容移植到博客，方便用户查找
- @swuferhong: 确认 LGTM
Issue #3085 Remote log consumption is stuck because the semaphore permit cannot be acquired
- @wguo-talend: 提供了防御性信号量管理方案，确保异常时正确释放许可
Issue #3091 [server] RemoteLogFetcher optimize to async downloading
- @fresh-borzoni: 表示可以帮忙优化，之前在 Rust SDK 中做过类似优化
Issue #3098 [helm] Support injecting environment variables and external secrets
- @fresh-borzoni: 请求 reviewer 审阅 PR
PR Review
PR #2855 [kv] Support downloading CDC log segments from remote storage during KV table recovery
- @wuchong: 建议延迟创建临时目录、移除重复代码、添加测试验证清理逻辑，并追踪异步下载优化
- @swuferhong: 添加了单元测试验证陈旧目录在恢复后会被清理
PR #2997 [filesystem][bug] Fix client.fs.* config prefix not stripped before passing to…
- @morazow: 建议更新 Javadoc、添加测试用例，发现使用 flussConfig 而非 hadoopConfig 的预存 bug
- @fresh-borzoni: 修复了预存 bug，添加了测试，内联了 get 调用中的 keys
PR #3067 [filesystem] Support default AWS credential chain for S3 delegation
- @michaelkoepf: 建议使用 checkArgument 替代 checkNotNull 保持一致性，并验证 region 配置
- @fresh-borzoni: 已处理所有 review 评论，添加文档和测试
PR #3042 [spark] Support batch union read for lake-enabled primary key tables
- @Copilot: 指出投影顺序问题、错误消息语法、Scaladoc 不准确、测试中非分区表等待逻辑问题等多个改进建议
PR #3076 [lake/tiering] add tiering table pending time and freshness metrics
- @Copilot: 指出 pendingTime 使用 0L 作为哨兵值会在时间戳为 0 时出问题，建议使用 null 或负数哨兵
PR #2924 [server] Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled
- @wuchong: 建议将 validateTableDescriptor 移到 createTable 之前避免孤立表；改进文档说明配置组合行为
📝 新建 Issue/PR
Issues
- #3097 [helm] Support injecting environment variables and external secrets @fresh-borzoni
- #3096 [server] Add timeout mechanism for rebalance tasks to prevent indefinite blocking on missing completion events @swuferhong
- #3095 [flink] Skip emitting update events when only non-projected columns are modified in source connector @wuchong component=connector/flink
- #3093 [docs] Fix table cell overflow into sidebar @fresh-borzoni
- #3091 [server] RemoteLogFetcher optimize to async downloading @swuferhong
- #3085 Remote log consumption is stuck because the semaphore permit cannot be acquired @zuston
- #3084 Flink log table consumer threw an out-of-range offset exception @zuston
- #3083 [test] Unstable test RemoteLogITCase.testRemoteLogTTLWithDynamicLakeToggle @app/github-actions
- #3080 Add fluss-microbench module: YAML-driven performance testing framework @platinumhamburg
Pull Requests
- #3098 [helm] Support injecting environment variables and external secrets @fresh-borzoni
- #3088 [Blog] Column Pruning @polyzos
- #3087 [docs] Add documentation for how contributors can become committers @matrixsparse
- #3082 Add fluss-microbench module with YAML-driven perf framework and JMH benchmarks @platinumhamburg
✅ 关闭 Issue/PR
已关闭 Issues
- #3093 [docs] Fix table cell overflow into sidebar @fresh-borzoni
- #3075 [lake/tiering] Add pendingTime and freshness metrics for lake tiering tables @beryllw
- #3066 [filesystem] S3 credential delegation requires static keys, blocking IRSA/IAM role usage @fresh-borzoni
- #3025 Replace Netty PooledByteBufAllocator with bump-pointer ChunkedAllocationManager for Arrow memory allocation @loserwang1024
- #2996 [filesystem][bug] client.fs.* config silently ignored by all filesystem plugins @fresh-borzoni
- #2853 [Feature] Support downloading CDC log segments from remote storage during KV table recovery @swuferhong
- #2663 [Umbrella] Improve Direct Memory OOM in client side. @loserwang1024
已合并 PRs
- #3094 [backport][release-0.9][filesystem] Support default AWS credential chain for S3 delegation (… @fresh-borzoni
- #3092 [docs] chore: fix overlapping table and sidebar in docs @fresh-borzoni
- #3090 [release-0.9][backport] Fix OOB in partial update/delete after ADD COLUMN @fresh-borzoni
- #3089 [hotfix[ blog title @polyzos
- #3086 [website] Hide left sidebar for blog page and improve the fonts @wuchong
- #3079 [Blog] Realtime UV Dedup @polyzos
- #3076 [lake/tiering] add tiering table pending time and freshness metrics @beryllw
- #3071 [server] Make leader-only rebalance tasks execute sequentially @swuferhong
- #3067 [filesystem] Support default AWS credential chain for S3 delegation @fresh-borzoni
- #3026 [client] Replace Netty PooledByteBufAllocator with bump-pointer ChunkedAllocationManager for Arrow memory allocation. @loserwang1024
- #2997 [filesystem][bug] Fix client.fs.* config prefix not stripped before passing to… @fresh-borzoni
- #2855 [kv] Support downloading CDC log segments from remote storage during KV table recovery @swuferhong