📝 7 新 Issues
✅ 3 关闭
✨ 4 新 PRs
🎉 5 合并
⚠️ 重点关注
- ⚠️ Issue #2938 测试不稳定：BatchScannerITCase.testScanSnapshot
- ⚠️ Issue #2937 测试不稳定：Flink119TableSinkITCase.testWritePartitionedTable
- ⚠️ Issue #2935 Flaky test: TableChangeWatcherTest.testSchemaChanges
💬 Issue/PR 动态
Issue 讨论
Issue #2922 [docs] Add AGENTS.md - AI agent coding guide
- @qzyu999: 对比 Airflow AGENTS.md，建议添加 git 命令指导和边界说明，建议用符号链接保持文件简洁
- @vaibhavk1992: 压缩文件到 500 行以内，添加 Airflow 相关内容，添加 CLAUDE.md 符号链接
Issue #2940 [fluss-common] Validate partition time when creating partition on auto partition table
- @platinumhamburg: 发现 DynamicPartitionCreator 状态泄漏问题，建议将验证移到修改 inflight 集合之前
- @loserwang1024: 接受建议并修改了验证位置
Issue #2780 [Feature] Support coordinator switch when leader fail
- @zcoo: 解释了必须创建独立选举线程的原因：避免 Curator 事件线程执行 ZK 请求导致的死锁
Issue #2700 [helm] Enable SASL authenticated connection to Zookeeper nodes
- @affo: 建议统一命名风格，使用与 listeners security 相同的 mechanism 设计
- @morazow: 确认内部和客户端 listener 机制的区分逻辑
Issue #2373 [Client] Fail Log Scanner when table is dropped during scan
- @beryllw: 建议直接查询 ZooKeeper 检查表和分区删除状态，而非依赖缓存
Issue #2669 [docs] Add Real-Time User Profile quickstart tutorial
- @platinumhamburg: 建议在初始实现中添加 rb_or_agg 函数，以便在快速入门中展示 roll-up 查询示例
Issue #2934 [Blog] Fluss Rust SDK introduction blog
- @fresh-borzoni: 计划稍后添加图表，目前专注于文字和流程确认
- @leekeiabstraction: 建议添加图表位置
Issue #2933 [lake/tiering] add bytes written tracking and metrics for tiering service
- @leekeiabstraction: 关注 LanceLakeWriter 未实现 getBytesWritten() 可能影响 tiering 指标
Issue #2886 Add V2 batch format with statistics collection
- @platinumhamburg: 感谢贡献，这是一个很扎实的改进
Issue #2875 [Feature] Support for VARIANT data type
- @wuchong: 关闭此 PR，需要先进行 FIP 讨论设计方案
PR Review
PR #2920 [lake/tiering] add table dropped handling and nullable write results
- @luoyuxia: 建议处理 split 移动后表被删除的异常情况，并指出 poll 不会抛出 TableNotExistException
PR #2922 [docs] Add AGENTS.md - AI agent coding guide
- @qzyu999: 建议文档保持 AI 代理无关性，使用 '' 占位符，添加 CLAUDE.md 符号链接
- @vaibhavk1992: 已按要求添加 CLAUDE.md 符号链接，AI 辅助贡献指南将放在第二阶段
PR #2940 [fluss-common] Validate partition time when creating partition on auto partition table
- @platinumhamburg: 发现 DynamicPartitionCreator 状态泄漏问题，建议将验证提前到修改 inflight 集合之前
- @loserwang1024: 接受建议并完成修改
PR #2931 [flink] Remove redundant `bucket.num` and `bucket.key` from customer properties
- @beryllw: 建议将 'customer properties' 改为 'custom properties'
- @loserwang1024: 已完成修改
📝 新建 Issue/PR
Issues
- #2946 Azure FS token delegation does not take effect @affo
- #2943 Fix NoSuchElementException that occurs when recovering log segments @pisceslj
- #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
Pull Requests
- #2947 [fs/azure] Set auth.type=Custom for token delegation @affo
- #2945 [hotfix] Check if batches is empty to prevent readNextOffset from throwing NoSuchElementException. @pisceslj
- #2942 [server] Fix TabletServer fails to restart after unclean shutdown due to EOFException in log recovery @LiebingYu
- #2936 [hotfix] Fix flaky TableChangeWatcherTest by awaiting CuratorCache init @platinumhamburg
✅ 关闭 Issue/PR
已关闭 Issues
- #2939 Need to validate auto-partition time when creation and write new partition @loserwang1024
- #2885 [common] Add V2 batch format with statistics collection for filter pushdown @platinumhamburg
- #2677 [helm] Enable metrics reporting on helm charts @morazow
已合并 PRs
- #2940 [fluss-common] Validate partition time when creating partition on auto partition table. @loserwang1024
- #2931 [flink] Remove redundant `bucket.num` and `bucket.key` from customer properties. @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