📝 3 新 Issues
✅ 3 关闭
✨ 7 新 PRs
🎉 5 合并
⚠️ 重点关注
- ⚠️ PR #2829 存在 P1 问题：rebalance 逻辑未考虑 standby 副本，可能导致选主错误
- ⚠️ PR #2829 存在 P2 问题：ISR 扩展时 standby 列表未更新
- ⚠️ Issue #2982 测试 CommitRemoteLogManifestITCase 不稳定
💬 Issue/PR 动态
Issue 讨论
Issue #1519 Update documentation about the default JDK version to Java11
- @binary-signal: 指出 Fluss 官网已说明需要 Java 11，建议关闭此 issue
Issue #2891 [server] Throttle replica deletion on Coordinator startup to prevent event queue starvation
- @wattt3: 认领此 issue，计划通过 ResumeDeletionEvent 和 ScheduledExecutorService 实现
Issue #2969 [kv] Fix non-target columns not being nulled during partial update on first insert
- @luoyuxia: 建议移除冗余测试方法，复用已有测试逻辑
- @binary-signal: 已处理 review 意见并回复
Issue #3085 Remote log consumption is stuck because the semaphore permit cannot be acquired
- @zuston: 确认将在下周一为 release-0.9 分支提交修复 PR
Issue #3120 [docs] Add security reporting documentation
- @luoyuxia: 建议采纳 Copilot 的措辞优化建议，使文档更清晰
- @matrixsparse: 已根据建议更新文档措辞
Issue #3129 [Test] Unstable test SparkStreamingTest read: log table
- @Yohahaha: 分析了竞态条件根因，提供了详细的时序图和修复方案
Issue #3135 [client] Fix early termination in SortMergeReader on changelog deletes
- @Copilot: 建议优化 hasNext() 中的 continue 逻辑以减少每行开销
- @beryllw: 确认 PR LGTM
Issue #3140 [POC][client] Support log scanner for multiple tables
- @wuchong: 建议保持 API 不变，在 LogFetcher 层面共享 I/O，与 writer 侧策略一致
Issue #3142 [spark][doc] Add Spark batch union read
- @Yohahaha: 请求 @wuchong @YannByron @luoyuxia 帮助 review
PR Review
PR #2829 [kv] Support elect standby replicas for primary key table
- @Copilot: 多处代码建议：isStandbyReplica 状态不一致、变量命名优化、反序列化健壮性等
- @wuchong: 提出 P1/P2 问题：rebalance 选主错误、standby 列表未更新、代码简化建议
PR #2836 [FLUSS-2686] Add COS filesystem support
- @XuQianJin-Stars: 添加了 COSWithCredentialsProviderFileSystemBehaviorITCase 测试覆盖
PR #3030 [server] Implement JBOD Phase 1 Local Multi-Directory Support
- @gyang94: 多处代码改进建议：异常处理、路径规范化、trim 调用优化
PR #3078 [server] Add authorization to databaseExists and tableExists RPC call…
- @Copilot: 建议使用 isAuthorized 替代 try-catch 进行权限检查
- @wuchong: 建议先检查权限（fail-fast），使用 isAuthorized 替代异常处理
PR #3116 [spark] Support filter pushdown for log tables
- @Yohahaha: 建议将测试加入现有测试套件，测试分区表，保持 Scala 风格
PR #3135 [client] Fix early termination in SortMergeReader on changelog deletes
- @Copilot: 建议优化 hasNext() 中 continue 逻辑以减少开销
📝 新建 Issue/PR
Issues
- #3139 Support log scanner for multiple tables. @loserwang1024
- #3138 [Feature]Support managing existing Apache Iceberg tables with Fluss @litiliu
- #3134 [client] SortMergeReader stops after deleted snapshot rows @luoyuxia
Pull Requests
- #3143 [filesystem] Add support for client delegation tokens @morazow
- #3142 [spark][doc] Add Spark batch union read @Yohahaha
- #3141 [spark] Fix flaky SparkStreamingTest by handling interruption when close streaming execution @Yohahaha
- #3140 [POC][client] Support log scanner for multiple tables @loserwang1024
- #3133 [flink] Support batch read for tables without datalake enabled @binary-signal
- #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery @Kaixuan-Duan
- #3131 [server] Resume deletions off startup via scheduled event @wattt3
✅ 关闭 Issue/PR
已关闭 Issues
- #3134 [client] SortMergeReader stops after deleted snapshot rows @luoyuxia
- #3103 Java.lang.NoSuchFieldError: JAVA_9 @loserwang1024
- #3101 java.lang.IllegalArgumentException: Accounted size went negative. @loserwang1024
已合并 PRs
- #3137 [client] Backport SortMergeReader changelog delete fix to 0.9 @luoyuxia
- #3136 [client] Catch throwable to avoid slient failure on remote file download (#3104) @zuston
- #3135 [client] Fix early termination in SortMergeReader on changelog deletes @luoyuxia
- #3113 [common] Remove MapUtils.newConcurrentMap() to avoid dependencies conflict. @loserwang1024
- #3102 [client] release the resource of record accumulator only when sender thread is stopped. @loserwang1024