📝 5 新 Issues
✅ 2 关闭
✨ 5 新 PRs
🎉 4 合并
⚠️ 重点关注
- ⚠️ Issue #3016 不稳定测试 TableManagerITCase.testSchemaEvolution 需要关注
- ⚠️ Issue #2992 RemoteLogScannerITCase 测试不稳定，可能与零拷贝相关
💬 Issue/PR 动态
Issue 讨论
Issue #2730 [blog] Fluss rust / python / c++ client release blog draft
- @polyzos: 建议今天合并，询问是否与 #2934 分不同天发布
- @leekeiabstraction: 建议先发布此博客，下周再发布另一篇以维持关注度
Issue #2992 [test] Unstable test RemoteLogScannerITCase.testScanFromRemoteAndProject
Issue #2956 [spark] Add union read for lake-enabled log tables
- @Yohahaha: 提出代码改进建议并询问测试跳过原因
- @fresh-borzoni: 感谢审查意见，确认依赖问题已解决
Issue #2998 Fix unreleased buffer in LimitScanResponse and evaluate client-side zero-copy OOM risk
- @fresh-borzoni: 关联到 PR #3008 的零拷贝修复
Issue #3002 [test] chore: fix flaky RemoteLogScannerITCase
- @wuchong: 报告本地测试失败，提供详细错误日志
- @fresh-borzoni: 指出问题与 PR #3008 零拷贝相关，buffer 被覆盖导致数据损坏
PR Review
PR #2987 [spark][bugfix] Use pk index for comparator align with SortMergeReader
- @YannByron: 指出需要输入数据的行类型而非仅主键行类型
- @Yohahaha: 解释 PK 列不位于开头时 UT 失败的原因，只需 PK 列即可
PR #2995 [client] Support log scanner scan to arrow record batch
- @luoyuxia: 解释保留 Arrow 依赖的设计原因及 retain() 的必要性
- @Copilot: 建议使用 Arrow vector transfer 优化性能，建议 CompletedFetch 保持 package-private
PR #2972 [flink] Implement SupportsWatermarkPushDown for FlinkTableSource
- @loserwang1024: 担心此 PR 可能破坏之前作业的状态恢复兼容性
📝 新建 Issue/PR
Issues
- #3016 [test] Unstable test TableManagerITCase.testSchemaEvolution @wuchong
- #3011 [fluss-server] Fix replicasOnOffline deadlock in addFetcherForReplicas @platinumhamburg
- #3009 [server] Handle corrupt log data after unclean shutdown to prevent TabletServer startup failure @platinumhamburg
- #3006 [client] Implement adaptive fetch rate control for LogScanner to reduce overhead on partitioned tables @swuferhong
- #3005 [client][server] Support dynamically modifying table.auto-increment.cache-size via ALTER TABLE @matrixsparse
Pull Requests
- #3015 [helm] Fix Zookeeper client config path @morazow
- #3013 [lake/lance] Implement Lance LakeSource read path with pushdown and enhanced split semantics @fhan688
- #3012 [fluss-server] Fix replicasOnOffline deadlock with enhanced diagnostics @platinumhamburg
- #3008 [client] Fix corruption after zero-copy lazy parse ByteBuf @fresh-borzoni
- #3007 [client] Implement adaptive fetch rate control for LogScanner @swuferhong
✅ 关闭 Issue/PR
已关闭 Issues
- #3009 [server] Handle corrupt log data after unclean shutdown to prevent TabletServer startup failure @platinumhamburg
- #2986 [spark][bug] Batch read PK table failed when use random column as primary key @Yohahaha
已合并 PRs
- #3014 [blog] Fix rust client release blog: save avatars locally and add truncate @luoyuxia
- #2999 Update version to 1.0-SNAPSHOT @wuchong
- #2987 [spark][bugfix] Use pk index for comparator align with SortMergeReader @Yohahaha
- #2730 [blog] Fluss rust / python / c++ client release blog draft @leekeiabstraction