📝 11 新 Issues
✅ 7 关闭
✨ 5 新 PRs
🎉 8 合并
🔥 核心要点
- 🎉 PR #2594 修复了 ADD COLUMN 后部分更新时的 ArrayIndexOutOfBoundsException 问题
- 🎉 PR #2780 新增 Leader 故障时的 Coordinator 切换支持
- 🚀 PR #2948 客户端零拷贝延迟解析 ByteBuf 避免深拷贝，提升性能
- 🐛 PR #2978 修复 PeriodicSnapshotManager.start() 静默跳过调度的问题
- 📚 PR #2922 添加 AGENTS.md - AI agent 编码指南文档
⚠️ 重点关注
- ⚠️ Issue #2986 Spark 批量读取 PK 表时使用随机列作为主键失败
- ⚠️ Issue #2982 不稳定测试: CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit
💬 Issue/PR 动态
Issue 讨论
Issue #2007 Add missing authentication for RPC calls
- @vaibhavk1992: 提出两阶段方案：外部 RPC 和内部 RPC 的授权检查，询问是否有参考设计文档
- @LiebingYu: 确认任务分配，建议将缺失的认证方法分类并在多个 PR 中实现
Issue #2956 [spark] Add union read for lake-enabled log tables
- @fresh-borzoni: 说明 PR 已实现 log 表批量联合读取，PK 表联合读取后续跟进
- @Yohahaha: 建议在 PR 描述中添加 "closes #2983" 链接对应 issue
Issue #2976 Introduce RPC Layer for KV Scan
- @polyzos: 处理了 CI 不稳定问题，请求 reviewer 审阅
- @fresh-borzoni: 质疑 close-scanner 请求是否会导致序列化膨胀，询问异常类差异
PR Review
PR #2951 [server] Add server-side filter execution and client-side integration
- @wuchong: 建议移除 null count 缓存相关改动到单独 PR，指出缓存 key 缺少 tableId
PR #2972 [flink] Implement SupportsWatermarkPushDown for FlinkTableSource
- @Copilot: 指出全局配置覆盖可能影响其他测试，建议断言使用稳定子串而非完整计划
- @loserwang1024: 询问 providerContext.generateUid() 的用途
- @LiebingYu: 解释 uid 对 Flink 状态管理很重要，参考了 Kafka connector 实现
PR #2956 [spark] Add union read for lake-enabled log tables
- @Yohahaha: 建议合并分区时保持纯函数，询问方法参数含义，建议引入 tiering 测试模块
- @fresh-borzoni: 同意拆分测试模块的建议
PR #2976 Introduce RPC Layer for KV Scan
- @fresh-borzoni: 质疑 close-scanner 请求可能造成序列化膨胀，询问异常类之间的区别
- @leekeiabstraction: 建议将 closeScanRequest 拆分为独立请求，保持 API 单一职责
📝 新建 Issue/PR
Issues
- #2988 ArrayIndexOutOfBoundsException in partial updates after ADD COLUMN @fresh-borzoni
- #2986 [spark][bug] Batch read PK table failed when use random column as primary key @Yohahaha
- #2985 [spark] Add spark tiering service @Yohahaha
- #2984 [spark] Batch union read for pk table @Yohahaha
- #2983 [spark] Batch union read for log table @Yohahaha
- #2982 [test] Unstable test CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit @app/github-actions
- #2979 Paimon sorted reader fails when primary key contains TIMESTAMP @luoyuxia
- #2977 [Server] PeriodicSnapshotManager.start() silently skips scheduling when initialDelay is 0 @platinumhamburg
- #2975 [test] Unstable test CoordinatorEventProcessorTest.testDoBucketReassignment @app/github-actions
- #2974 [test] Unstable test RebalanceManagerITCase.testRebalanceWithRemoteLog @app/github-actions
- #2971 [flink] FlinkTableSource should implement SupportsWatermarkPushDown @LiebingYu
Pull Requests
- #2987 [spark][bugfix] Use pk index for comparator align with SortMergeReader @Yohahaha
- #2981 [WIP] Support variant type and shredding @swuferhong
- #2976 Introduce RPC Layer for KV Scan @polyzos
- #2972 [flink] Implement SupportsWatermarkPushDown for FlinkTableSource @LiebingYu
- #2970 [WIP] feat: log sub batch poc @gyang94
✅ 关闭 Issue/PR
已关闭 Issues
- #2988 ArrayIndexOutOfBoundsException in partial updates after ADD COLUMN @fresh-borzoni
- #2979 Paimon sorted reader fails when primary key contains TIMESTAMP @luoyuxia
- #2977 [Server] PeriodicSnapshotManager.start() silently skips scheduling when initialDelay is 0 @platinumhamburg
- #2961 Allow enabling lakehouse for log tables without bucket key created before cluster-level lakehouse is enabled @luoyuxia
- #2932 [lake/tiering] add total bytes read tracking and metrics for tiering service @beryllw
- #2770 [Feature] Support coordinator switch when leader fail @zcoo
- #1184 Client lazy parse ByteBuf to avoid deeply memory copy @swuferhong
已合并 PRs
- #2980 [lake/paimon] Fix Paimon PK comparator row type @luoyuxia
- #2978 [Server] Fix PeriodicSnapshotManager.start() silently disables snapshot @platinumhamburg
- #2973 [server] Allow enabling lakehouse for log tables without bucket key created before cluster-level lakehouse is enabled @luoyuxia
- #2948 [rpc] Client zero-copy lazy parse ByteBuf to avoid deep memory copy @fresh-borzoni
- #2933 [lake/tiering] add total bytes read tracking and metrics for tiering service @beryllw
- #2922 [docs] Add AGENTS.md - AI agent coding guide @vaibhavk1992
- #2780 [Feature] Support coordinator switch when leader fail @zcoo
- #2594 [BugFix] Fix ArrayIndexOutOfBoundsException in partial updates after ADD COLUMN @fresh-borzoni