📝 4 新 Issues
✅ 3 关闭
✨ 8 新 PRs
🎉 5 合并
🔥 核心要点
- 🐛 PR #2926 修复 ReplicaFetcherThread 在 fetchLog RPC 超时时的 Netty ByteBuf 内存泄漏问题
- 🎉 PR #2763 扩展元数据模型以支持每表/分区的远程数据目录
- 🐛 PR #2919 当 datalake format 不为空时跳过 datalake 前缀验证
- ✨ PR #2934 新增 Fluss Rust SDK 介绍博客文章
- 📚 PR #2923 新增 C++ 客户端文档
⚠️ 重点关注
- ⚠️ PR #2780 P1 问题：选举线程返回的 Future 未正确链接到错误处理，可能导致协调器静默失败
- ⚠️ PR #2780 P3 问题：注册协调器时未携带 payload，导致 NewCoordinatorEvent 和 DeadCoordinatorEvent 永远不会触发
💬 Issue/PR 动态
Issue 讨论
Issue #2448 [Docs] Add documentation for C++ Client
- @leekeiabstraction: 将该任务分配给 @Prajwal-banakar，询问其是否愿意接手
- @Prajwal-banakar: 确认接受任务并提交了 PR
Issue #2669 [docs] Add Real-Time User Profile quickstart tutorial
- @platinumhamburg: 建议将 RoaringBitmap 插件迁移到 flink-extended/flink-roaringbitmap 仓库
- @Prajwal-banakar: 同意迁移方案，并在邮件列表提出了 Native Bitmap 集成讨论
Issue #2886 Add V2 batch format with statistics collection
- @wuchong: 指出 AlignedRow 和 StatisticsColumnsConfig 代码覆盖率低于 70% 的最低要求
- @platinumhamburg: 感谢 @wuchong 的详细专业评审，已根据反馈优化修复
Issue #2922 [docs] Add AGENTS.md - AI agent coding guide
- @qzyu999: 对比 Airflow 的 AGENTS.md，建议添加 git 命令指南和边界定义，并讨论文档长度平衡
Issue #2926 [hotfix] Fix Netty ByteBuf leak on follower fetchLog timeout
- @wuchong: 指出 CI 编译失败，是 LanceTieringTest.java 的预存问题
- @platinumhamburg: 解释 CI 失败非本 PR 引起，已用 retry() 替换 Thread.sleep 修复不稳定测试
PR Review
PR #2700 [helm] Enable SASL authenticated connection to Zookeeper nodes
- @affo: 建议不应生成凭证而应直接失败，Fluss 不管理 ZK 服务器
PR #2780 [Feature] Support coordinator switch when leader fail
- @wuchong: 指出选举线程设计冗余，建议在 LeaderLatchListener 中直接处理；要求添加 leader 变 follower 后重新选举的测试
PR #2886 Add V2 batch format with statistics collection
- @wuchong: 提供大量详细评审：建议用白名单替代黑名单验证类型、推荐直接写入 pagedOutputView 避免拷贝、要求添加零行测试用例
PR #2924 [server] Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled
- @Copilot: 指出 datalake.enabled 验证逻辑反转错误，建议从 newConfig 而非 currentConfiguration 获取 format
- @wuchong: 要求更新文档说明兼容性问题，下游任务需先升级到 Fluss v1.0+ 才能解析 V1/V2 格式日志
PR #2934 [Blog] Fluss Rust SDK introduction blog
- @leekeiabstraction: 建议提及社区计划将 fluss-rust 移入主仓库，并讨论持久性保证和部分更新的文档说明
📝 新建 Issue/PR
Issues
- #2932 [lake/tiering] add total bytes read tracking and metrics for tiering jobs @beryllw
- #2925 [Server] Netty ByteBuf leak in ReplicaFetcherThread when fetchLog RPC times out @platinumhamburg
- #2921 Add AGENTS.md coding guide for AI agents @vaibhavk1992
- #2918 Skip datalake prefix validation when datalake format is not null @loserwang1024
Pull Requests
- #2934 [Blog] Fluss Rust SDK introduction blog @fresh-borzoni
- #2933 [lake/tiering] add total bytes read tracking and metrics for tiering service @beryllw
- #2931 [flink] Remove redundant `bucket.num` and `bucket.key` from customer properties. @loserwang1024
- #2930 [IT][fix]ServerITCaseBase fails when stderr contains "Picked up JAVA_TOOL_OPTIONS" @litiliu
- #2924 [server] Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled @luoyuxia
- #2923 [docs] Add C++ client documentation @Prajwal-banakar
- #2922 [docs] Add AGENTS.md - AI agent coding guide @vaibhavk1992
- #2920 [lake/tiering] add table dropped handling and nullable write results @beryllw
✅ 关闭 Issue/PR
已关闭 Issues
- #2925 [Server] Netty ByteBuf leak in ReplicaFetcherThread when fetchLog RPC times out @platinumhamburg
- #2918 Skip datalake prefix validation when datalake format is not null @loserwang1024
- #2754 [server] Extend metadata models to support per-table/partition remote data directory @LiebingYu
已合并 PRs
- #2928 [hotfix][lance] Fix compile problem in LanceTieringTest @wuchong
- #2927 [hotfix] update TableInfo constructor call in LanceTieringTest @beryllw
- #2926 [hotfix] Fix Netty ByteBuf leak on follower fetchLog timeout @platinumhamburg
- #2919 [server] Skip datalake prefix validation when datalake format is not null @loserwang1024
- #2763 [server] Extend metadata models to support per-table/partition remote data directory @LiebingYu