📝 9 新 Issues
✅ 6 关闭
✨ 2 新 PRs
🎉 4 合并
🔥 核心要点
- 🎉 PR #2958 Skip LogSplit for empty buckets in lake union read - 修复 lake union 读取空 bucket 问题
- 🎉 PR #2953 Skip blocked bucket instead of stopping drain loop - 优化客户端阻塞处理
- 🎉 PR #2947 Set auth.type=Custom for Azure token delegation - 修复 Azure 文件系统认证问题
- 📚 PR #2923 Add C++ client documentation - 新增 C++ 客户端文档
- 🐛 Issue #2967 Fix OutOfBoundException in writeChangeType when records are large - 修复大量记录写入越界异常
💬 Issue/PR 动态
Issue 讨论
Issue #2934 [Blog] Fluss Rust SDK introduction blog
- @fresh-borzoni: 将添加图表并完成博客内容
- @luoyuxia: 确认博客结构，支持推进
Issue #2780 [Feature] Support coordinator switch when leader fail
- @zcoo: 已处理 review 意见
- @wuchong: 重构代码，将合并此 PR
Issue #2669 [docs] Add Real-Time User Profile quickstart tutorial
- @polyzos: 建议简化 quickstart，扩展内容放博客
- @Prajwal-banakar: 同意简化方案，将创建独立博客文章
Issue #2730 [blog] Fluss rust / python / c++ client release blog draft
- @leekeiabstraction: 更新博客内容和作者列表
- @fresh-borzoni: 建议添加贡献者列表和功能说明
- @luoyuxia: 建议修改标题格式并添加标签
Issue #2900 [fluss-client] Support Complex Data Types on the Java API (NestedRow/ROW)
- @polyzos: Review 反馈，指出性能和类型安全问题
Issue #437 TieringService support convert arrow to parquet directly
Issue #2963 Support direct Arrow RecordBatch to Parquet conversion
- @luoyuxia: 被 apache/arrow-java PR 阻塞
Issue #2947 [fs/azure] Set auth.type=Custom for token delegation
- @polyzos: 指出 URI 和配置设置问题
- @affo: 解释 auth.type 设置逻辑并修复文档
Issue #2662 [filesystem] Enhance S3 filesystem with independent credentials provider for token delegation
- @michaelkoepf: 询问是否可直接使用完整方案
- @affo: 确认将在接下来几周实现
Issue #2948 [rpc] Client zero-copy lazy parse ByteBuf to avoid deep memory copy
- @polyzos: 指出 retain() 在无记录时不应调用
PR Review
PR #2933 [lake/tiering] add total bytes read tracking and metrics for tiering service
- @luoyuxia: 指出字节计算和指标名称的语义问题
- @leonardBang: 建议在提交时计算，澄清指标与 Flink CDC 区别
- @beryllw: 解释 tiering job 架构与 Flink CDC 不同
- @leekeiabstraction: 建议使用更精确的断言和异常处理
PR #2920 [lake/tiering] add table dropped handling and nullable write results
- @luoyuxia: 建议统一错误处理路径和保留注释
PR #2855 [kv] Support downloading CDC log segments from remote storage during KV table recovery
- @platinumhamburg: 指出资源泄漏、offset 处理和测试覆盖问题
PR #2769 [server] Integrate remote directory selector into table/partition creation
- @Copilot: 指出配置合并、变更检测和资源安全问题
PR #2594 [TASK-2293] use column id instead of position in Partial Update
📝 新建 Issue/PR
Issues
- #2968 Fluss Introduces ChangelogNormalize Operator In WAL Image Mode @polyzos
- #2967 Fix OutOfBoundException in writeChangeType when the number of records is large @gyang94
- #2966 TieringSourceReader adjust to scan arrow record batch and write arrow record batch to lake @luoyuxia
- #2965 support log scanner scan data as arrow reacord batch @luoyuxia
- #2963 Support direct Arrow RecordBatch to Parquet conversion @luoyuxia
- #2962 Support reading tiering source data as Arrow RecordBatch @luoyuxia
- #2961 Allow enabling lakehouse for log tables without bucket key created before cluster-level lakehouse is enabled @luoyuxia
- #2959 [server] Allowed to alter partition retention number @loserwang1024
- #2957 [flink] Skip LogSplit for empty buckets in lake union read @fresh-borzoni
Pull Requests
- #2969 [kv] Fix non-target columns not being nulled during partial update on first insert @binary-signal
- #2964 [server] allow user to alter partition nun retention. @loserwang1024
✅ 关闭 Issue/PR
已关闭 Issues
- #2968 Fluss Introduces ChangelogNormalize Operator In WAL Image Mode @polyzos
- #2957 [flink] Skip LogSplit for empty buckets in lake union read @fresh-borzoni
- #2946 Azure FS token delegation does not take effect @affo
- #2935 Flaky TableChangeWatcherTest.testSchemaChanges due to CuratorCache initial sync race @platinumhamburg
- #2448 [Docs] Add documentation for C++ Client @leekeiabstraction good first issue
- #1246 [file system] Add configuration option to enable/disable token delegation process for S3 file system (allows support for MinIO and other S3-compatible object stores) @michaelkoepf component=filesystem
已合并 PRs
- #2958 [flink] Skip LogSplit for empty buckets in lake union read @fresh-borzoni
- #2953 [client][backport] Skip blocked bucket instead of stopping drain loop @fresh-borzoni
- #2947 [fs/azure] Set auth.type=Custom for token delegation @affo
- #2923 [docs] Add C++ client documentation @Prajwal-banakar