📝 7 新 Issues
✅ 8 关闭
✨ 6 新 PRs
🎉 9 合并
🔥 核心要点
- 🎉 PR #2502 支持 Protobuf 和 RPC 层的谓词下推，为过滤器下推奠定基础
- 🎉 PR #2506 在 Helm Charts 中启用 SASL 认证配置
- 🐛 PR #2827 修复幂等生产者在响应丢失时进入无限重试循环的问题
- 🐛 PR #2857 修复 alterClusterConfigs 返回误导性 UnknownServerException 的问题
- 🐛 Issue #2892 新发现 ArrowWriter 内存双重释放导致 I/O 线程崩溃问题
💬 Issue/PR 动态
Issue 讨论
Issue #2809 [KV] Support Full KV Scan
- @platinumhamburg: 指出 scanner 生命周期、close_scanner 请求和错误处理等三个待解决问题
Issue #2779 [test][kv] ensure ordered inserts for auto-increment ID tests
- @beryllw: 详细分析 Flink UNION ALL 不保证顺序导致部分列 INSERT 结果非确定性的问题
- @leonardBang: 感谢 beryllw 的详细分析，认可调查结果
Issue #2871 [helm] Restructure helm chart of Fluss
- @affo: 建议使用 helm-docs 工具生成文档，推荐统一 Python 版本和 requirements.txt 管理
- @nhuantho: 回应 Helm schema 注释方式、开源工具选择和验证流程的建议
Issue #2711 [helm] Enable metrics reporting on helm charts
- @affo: 建议统一处理方式，禁止通过 config override 设置 reporters 和 ports
- @morazow: 已采纳建议，添加验证函数并更新相关配置逻辑
PR Review
PR #2827 [client] Fix idempotent writer enters infinite retry loop
- @wuchong: 建议调整异常检查块顺序，让 handleWriteBatchException 逻辑更清晰
- @LiebingYu: 已采纳建议并更新代码
PR #2880 [flink] Fix $binlog update pairing across log splits
- @Copilot: 警告 UPDATE_BEFORE 处理可能覆盖已缓冲记录，导致错误 binlog 输出
PR #2881 [lake/iceberg] Support snapshot expiration for lake tables
- @Copilot: 指出测试依赖 Thread.sleep 可能导致 CI 环境下测试不稳定
PR #2883 [hotfix] Still do remove server tag if tablet server not exist
- @swuferhong: 指出测试未覆盖 serverTag 存在于 ZK 但 server 已下线的场景
- @zcoo: 已请 reviewer 审核修改
- @swuferhong: 请求将 PR cherry-pick 到 release-0.9 分支
PR #2852 [server] Fix get table count of database
- @wuchong: 指出更改引入双重 I/O 开销，建议批量获取统计信息以并行化
PR #2781 [Feature] Coordinator Server Supports coordinator epoch protect
- @swuferhong: 指出 ioExecutor 双重初始化、BadVersionException 处理导致 split-brain 风险等多个问题
📝 新建 Issue/PR
Issues
- #2892 [client] Write sender I/O thread crashes with "Accounted size went negative" due to Arrow memory double-release in ArrowWriter @LiebingYu
- #2891 [server] Throttle replica deletion on Coordinator startup to prevent event queue starvation @LiebingYu
- #2889 [client] Support specifying rack when adding/removing server tags in Admin API @LiebingYu
- #2887 [flink] Allow partial updates for AGGREGATION merge engine @platinumhamburg
- #2885 [common] Add V2 batch format with statistics collection for filter pushdown @platinumhamburg
- #2882 [hotfix] Still do remove server tag if tablet server not exist @zcoo
- #2879 $binlog source may fail on interleaved updates from multiple log splits @luoyuxia
Pull Requests
- #2893 [helm][hotfix] Go template whitespace trimming caused exceptions @morazow
- #2890 [client] Support specifying rack when adding/removing server tags in Admin API @LiebingYu
- #2888 [flink] Allow partial updates for AGGREGATION merge engine @platinumhamburg
- #2886 Add V2 batch format with statistics collection @platinumhamburg
- #2881 [lake/iceberg] Support snapshot expiration for lake tables @vamossagar12
- #2880 [flink] Fix $binlog update pairing across log splits @luoyuxia
✅ 关闭 Issue/PR
已关闭 Issues
- #2882 [hotfix] Still do remove server tag if tablet server not exist @zcoo
- #2856 [server] Admin.alterClusterConfigs() returns UnknownServerException instead of ConfigException on validation failure @LiebingYu
- #2840 Remove redundant configuration specification in Helm README @affo
- #2826 [client] Idempotent producer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed @LiebingYu
- #2697 Fix license and notice issue @luoyuxia priority=blocker
- #2681 update Download page for Release 0.9 @luoyuxia priority=critical
- #2503 [helm] Enable SASL authentication configurations @morazow
- #2496 [FIP-10] Introduce Predicate in Protobuf and RPC Layer @polyzos
已合并 PRs
- #2884 [server] Still do remove server tag if tablet server not exist @zcoo
- #2883 [hotfix] Still do remove server tag if tablet server not exist @zcoo
- #2878 [docs] add trending tag @MehulBatra
- #2857 [server] Register ConfigException in Errors to fix misleading UnknownServerException from alterClusterConfigs @LiebingYu
- #2846 [helm] Rewrite README to point to website docs @affo
- #2827 [client] Fix idempotent writer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed @LiebingYu
- #2810 [fix] fix serialize modifiedTime field in TableRegistrationJsonSerde @gyang94
- #2506 [helm] Enable SASL authentication configurations @morazow
- #2502 Support Protobuf and RPC for Predicates @polyzos