📝 7 新 Issues
✅ 4 关闭
✨ 7 新 PRs
🎉 8 合并
🔥 核心要点
- 🎉 PR #2886 添加 V2 batch format 支持统计信息收集用于过滤器下推优化
- 🎉 PR #2711 在 Helm charts 中启用 metrics 报告功能
- 🐛 PR #2926 修复 ReplicaFetcherThread 中 fetchLog 超时导致的 Netty ByteBuf 内存泄漏问题
- 🐛 PR #2942 修复 TabletServer 非正常关闭后因日志恢复 EOFException 无法重启的问题
- 📚 PR #2934 添加 Fluss Rust SDK 介绍博客文章
⚠️ 重点关注
- ⚠️ Issue #2941 TabletServer 在非正常关闭后因日志恢复中的 EOFException 无法重启
- ⚠️ Issue #2938 不稳定测试 BatchScannerITCase.testScanSnapshot
- ⚠️ Issue #2937 不稳定测试 Flink119TableSinkITCase.testWritePartitionedTable
- ⚠️ Issue #2935 由于 CuratorCache 初始同步竞争导致 TableChangeWatcherTest.testSchemaChanges 测试不稳定
💬 Issue/PR 动态
Issue 讨论
Issue #2922 [docs] Add AGENTS.md - AI agent coding guide
- @qzyu999: 建议参考 Airflow 的 AGENTS.md，添加 git 命令指南和 AI 边界说明，并使用符号链接 CLAUDE.md 指向 AGENTS.md
- @vaibhavk1992: 已将文档压缩到 500 行以内，保留了所有检查项，并会按要求添加符号链接 CLAUDE.md
Issue #2669 [docs] Add Real-Time User Profile quickstart tutorial
- @platinumhamburg: 建议将 RoaringBitmap 插件移至 flink-extended/flink-roaringbitmap 仓库，并添加 BITMAP_OR_AGG 函数支持 roll-up 聚合示例
- @Prajwal-banakar: 同意迁移 UDF 到共享仓库，正在邮件列表讨论 Native Bitmap 集成方案
Issue #2886 Add V2 batch format with statistics collection
- @wuchong: 指出代码覆盖率问题：AlignedRow 和 StatisticsColumnsConfig 类覆盖率低于 70% 的最低要求
- @platinumhamburg: 感谢详细的审查意见，已根据反馈优化并解决了代码覆盖率问题
PR Review
PR #2924 [server] Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled
- @Copilot: 指出多个问题：datalake.enabled/datalake.format 验证逻辑反转、格式验证逻辑缺失、测试可能因共享集群扩展而变得不稳定
PR #2780 [Feature] Support coordinator switch when leader fail
- @wuchong: [P1] 指出选举线程的 Future 未链接到错误处理，可能导致进程假死；建议简化为直接在回调中调用而非使用额外线程
PR #2940 [fluss-common] Validate partition time when creating partition on auto partition table.
- @platinumhamburg: 指出 DynamicPartitionCreator 存在状态泄漏问题：验证失败后分区仍留在 inflight 集合中，建议将验证移到添加状态之前
PR #2926 [hotfix] Fix Netty ByteBuf leak on follower fetchLog timeout
- @wuchong: 指出固定 Thread.sleep 无法保证测试可靠性，建议改用基于条件的重试机制
- @platinumhamburg: 已改用 retry() 条件等待机制，测试会轮询直到所有 ByteBuf 的 refCnt == 0，15秒超时
PR #2934 [Blog] Fluss Rust SDK introduction blog
- @leekeiabstraction: 建议添加图表增强可读性，提及社区计划将 fluss-rust 迁入主仓库，并考虑部分更新的使用场景
- @fresh-borzoni: 确认会在后续添加图表和视觉元素，目前先确定文本内容和结构
PR #2931 [flink] Remove redundant `bucket.num` and `bucket.key` from customer properties.
- @beryllw: 建议将 "customer properties" 改为 "custom properties"，有一个小的拼写错误
- @loserwang1024: 已完成修改
📝 新建 Issue/PR
Issues
- #2941 [server] TabletServer fails to restart after unclean shutdown due to EOFException in log recovery @LiebingYu
- #2939 Need to validate auto-partition time when creation and write new partition @loserwang1024
- #2938 [test] Unstable test BatchScannerITCase.testScanSnapshot @app/github-actions
- #2937 [test] Unstable test Flink119TableSinkITCase.testWritePartitionedTable @app/github-actions
- #2935 Flaky TableChangeWatcherTest.testSchemaChanges due to CuratorCache initial sync race @platinumhamburg
- #2932 [lake/tiering] add bytes written tracking and metrics for tiering service @beryllw
- #2925 [Server] Netty ByteBuf leak in ReplicaFetcherThread when fetchLog RPC times out @platinumhamburg
Pull Requests
- #2942 [server] Fix TabletServer fails to restart after unclean shutdown due to EOFException in log recovery @LiebingYu
- #2940 [fluss-common] Validate partition time when creating partition on auto partition table. @loserwang1024
- #2936 [hotfix] Fix flaky TableChangeWatcherTest by awaiting CuratorCache init @platinumhamburg
- #2934 [Blog] Fluss Rust SDK introduction blog @fresh-borzoni
- #2933 [lake/tiering] add bytes written tracking and metrics for tiering service @beryllw
- #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
✅ 关闭 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
- #2885 [common] Add V2 batch format with statistics collection for filter pushdown @platinumhamburg
- #2677 [helm] Enable metrics reporting on helm charts @morazow
已合并 PRs
- #2931 [flink] Remove redundant `bucket.num` and `bucket.key` from customer properties. @loserwang1024
- #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
- #2886 Add V2 batch format with statistics collection @platinumhamburg
- #2847 [helm] Fix .helmignore to not package tests @affo
- #2711 [helm] Enable metrics reporting on helm charts @morazow