📝 9 新 Issues
✅ 5 关闭
✨ 8 新 PRs
🎉 10 合并
💬 Issue/PR 动态
Issue 讨论
Issue #3145 [test] Unstable test RemoteLogDownloaderTest.testPrefetchNum
- @ankit-khare-2015: 认领了该问题并提交了修复 PR，请求社区指导下一步审批流程。
- @github-actions[bot]: 报告了 CI 中 RebalanceManagerITCase 测试失败的具体错误堆栈信息。
Issue #3048 [lake][iceberg] Iceberg does not support union read for primary key table
- @morazow: 询问删除向量在此场景的作用，建议通过预排序记录或特定 Reader 来解决。
Issue #2683 [docs] Reintroduce the fluss-quickstart-flink Docker image
- @luoyuxia: 将任务拆分为三个子任务：Flink 镜像回归、手动设置迁移、Spark 镜像规划。
PR Review
PR #3150 Reintroduce Quickstart Image
- @luoyuxia: 指出由于缺少 Snapshot 发布流程，需要回退到手动构建 Docker 镜像的方式。
- @Copilot: 指出了 Docker 构建中 Flink 版本硬编码和 Maven 仓库源缺失导致的构建失败风险。
- @polyzos: 询问是否需要保持与 Flink 1.20 的兼容性，而不是升级到 2.2。
PR #3151 [KV] Kvscan Server Side
- @Copilot: 指出 totalBytes 可能溢出以及 ScannerManager 关闭时的状态不一致风险。
PR #3152 [fluss/ai agent] enable ai doc agent on website
- @wuchong: 提醒 AI Agent 的外部域名白名单需要与 Apache 隐私团队协调审批。
- @MehulBatra: 提到 Apache Hudi 已在使用该 Agent，并确认集成方式可行。
PR #3141 [spark] Fix flaky SparkStreamingTest by handling interruption when close streaming execution
- @beryllw: 建议在中断时重新抛出 InterruptedException 而非仅记录警告，以便 Spark 捕获。
- @Yohahaha: 采纳建议，修改为重新抛出 InterruptedException。
📝 新建 Issue/PR
Issues
- #3161 [docs] Reintroduce a prebuilt fluss-quickstart-flink image for the main quickstart @luoyuxia
- #3162 [docs] Move the manual JAR + Docker Compose Flink setup into Engine Flink getting started @luoyuxia
- #3163 [docs] Plan a fluss-quickstart-spark image for Spark Quickstart @luoyuxia
- #3160 [spark] Improve spark ui more readable when reading fluss @Yohahaha
- #3155 Introduce generic secondary index metadata foundation @platinumhamburg
- #3153 [helm] Add pod scheduling primitives (affinity, nodeSelector, tolerations, topologySpreadConstraints) @fresh-borzoni
- #3147 [server] Coordinator metrics not updated after restart when no events arrive @swuferhong
- #3145 [test] Unstable test RemoteLogDownloaderTest.testPrefetchNum @app/github-actions
- #3144 Batch reads on ``/`` fail with coordinator NPE instead of a clear unsupported error @luoyuxia
Pull Requests
- #3164 [spark] Exclude slf4j from spark connector shade @Yohahaha
- #3158 [client] Fix race condition in RemoteLogDownloader causing flaky testPrefetchNum @ankit-khare-2015
- #3156 Add generic secondary index metadata @platinumhamburg
- #3154 [helm] scheduling primitives @fresh-borzoni
- #3152 [fluss/ai agent] enable ai doc agent on website @MehulBatra
- #3151 [KV] Kvscan Server Side @polyzos
- #3149 [client] Ensure UPDATE_BEFORE and UPDATE_AFTER are never split across poll batches @loserwang1024
- #3148 [server] Fix coordinator metrics not updated when no events arrive @swuferhong
✅ 关闭 Issue/PR
已关闭 Issues
- #3161 [docs] Reintroduce a prebuilt fluss-quickstart-flink image for the main quickstart @luoyuxia
- #3074 add a page for reporting security issue @luoyuxia
- #3055 [flink] Fix NPE then flink reading in batch mode and "scan.startup.mode" is not "FULL". @gyang94
- #2843 Invalid partial update for PK table @zuston version: 0.9.1
- #2676 [spark] remove the warning info when insert data to a new partition @YannByron
已合并 PRs
- #3166 [cherry-pick][release-0.9] Reintroduce Quickstart Image (#3150) @luoyuxia
- #3165 [s3] Propagate path-style-access config from server to client via delegation token @luoyuxia
- #3157 [kv] Fix non-target columns not being nulled during partial update on first insert @luoyuxia
- #3150 Reintroduce Quickstart Image @polyzos
- #3146 [build] Add auto-generated docgen output to .gitignore @swuferhong
- #3120 [docs] Add security reporting documentation @matrixsparse
- #3056 [fix] fix: add lakeSource check in batch mode @gyang94
- #3019 [client] downgrade PartitionNotExistException log level when write data @YannByron
- #3003 Fix buffer leak in LimitBatchScanner @fresh-borzoni
- #2969 [kv] Fix non-target columns not being nulled during partial update on first insert @binary-signal