📝 2 新 Issues
✅ 3 关闭
✨ 2 新 PRs
🎉 3 合并
💬 Issue/PR 动态
Issue 讨论
Issue #3409 [test] fix flaky testRebalanceWithRemoteLog
- @Kaixuan-Duan: 指出该问题似乎与 #2974 相同。
- @swuferhong: 确认 #3313 已修复该问题，将合并代码，感谢贡献。
- @wattt3: 确认未注意到重复问题。
Issue #3346 [spark] Implement SupportsPushDownLimit DSv2 interface
- @fresh-borzoni: 请求 rebase 后将再次进行审查。
Issue #3390 [client] Fix stale metadata on readOnlyGateway by adding RetryableGatewayClientProxy
- @loserwang1024: 修改了设计：通过 refreshClusterUntilAvailable 循环重建元数据，避免过度工程化。
Issue #2747 [client] Abort write batch if table id changes.
- @fresh-borzoni: 请求 @wuchong 进行最终检查，若无异议明天将合并。
PR Review
PR #3397 [spark] Split non-partition and partition predicates from pushPredicates to limit pushdown
- @fresh-borzoni: 指出 PK 表读取 KV 快照时 ARROW filters 未应用，导致谓词浪费和误导。
- @Yohahaha: 回应称 PK 表谓词返回空集行为符合 Spark 预期。
PR #3388 [server]: remove orphan files and directories when tablet starts up
- @swuferhong: 建议使用 Files.delete 解决 TOCTOU 竞态，并指出分区删除时的孤儿文件清理漏洞。
PR #3404 [flink-action][server][client] add orphan files cleanup action for remote storage
- @Copilot: 指出异常处理丢失堆栈、线程池未关闭泄漏及敏感配置日志风险。
- @luoyuxia: 建议完善时区文档、跳过 shared SST 列表优化及设置强制并行度。
- @swuferhong: 指出 RPC 存在 partitionId 权限绕过风险，建议增加校验与异常映射。
PR #3395 [lake/hudi] Introduce Hudi LakeCatalog to create table
- @Copilot: 指出 ClassLoader 加载问题、敏感配置日志泄露风险及配置键前缀处理不一致。
PR #3174 [server] Add ReplicaCleanupManager to throttle drops in coordinator queue
- @Copilot: 指出 TableChangeWatcher 缓存无界增长及关闭后仍接受提交的安全隐患。
📝 新建 Issue/PR
Issues
- #3415 Add per-scanner dimension for scanner metrics @charlesdong1991
- #3413 [flink] Preserve tiering offsets for empty-batch buckets @luoyuxia
Pull Requests
- #3414 [lake] Reset lake filters for each pushdown @QuakeWang
- #3412 [WIP]complete delay fetch @gyang94
✅ 关闭 Issue/PR
已关闭 Issues
- #3385 [test] Unstable test RebalanceManagerITCase.testRebalanceWithRemoteLog @app/github-actions
- #3342 [spark] Implement SupportsPushDownLimit @Yohahaha
- #2974 [test] Unstable test RebalanceManagerITCase.testRebalanceWithRemoteLog @app/github-actions
已合并 PRs
- #3397 [spark] Split non-partition and partition predicates from pushPredicates to limit pushdown @Yohahaha
- #3346 [spark] Implement SupportsPushDownLimit DSv2 interface @Yohahaha
- #3313 [server] Fix flaky RebalanceManagerITCase.testRebalanceWithRemoteLog @Kaixuan-Duan