📝 7 新 Issues
✅ 6 关闭
✨ 4 新 PRs
🎉 6 合并
🔥 核心要点
- 🎉 PR #2976 引入 KV Scan 的 RPC 层，支持服务端 KvScan 功能
- 🎉 PR #2740 Spark 连接器支持 Map 类型
- 🎉 PR #3041 Spark 连接器支持 Scala 2.13
- 🎉 PR #3130 将博客内容迁移至独立仓库 apache/fluss-blog
- 🐛 PR #2924 修复集群级别 lakehouse 启用前创建的表无法启用 lakehouse 的问题
- 🚀 PR #3108 引入 netty.server.max-request-size 配置限制请求大小
💬 Issue/PR 动态
Issue 讨论
Issue #3128 [website] Move blog content to a separate repository
- @wuchong: 提议将博客内容迁移至独立仓库，主要维护开销在于 CSS 同步
- @polyzos: 同意迁移方案，图片资源长期会是问题，需要考虑额外开销
- @fresh-borzoni: 建议将整个网站拆分到独立仓库，而非仅博客内容
Issue #2969 [kv] Fix non-target columns not being nulled during partial update on first insert
- @binary-signal: 分析发现 FirstRowRowMerger 和 VersionedRowMerger 需要修复空值处理问题
Issue #3049 Introduce `netty.server.max-request-size` to limit the request size
- @wuchong: 已在 release-0.9 和 main 分支中修复此问题
Issue #3085 Remote log consumption is stuck because the semaphore permit cannot be acquired
- @zuston: 确认将在下周一提交 PR 处理此问题
Issue #2891 [server] Throttle replica deletion on Coordinator startup to prevent event queue starvation
- @wattt3: 认领此任务，计划通过 ScheduledExecutorService 实现 ResumeDeletionEvent
Issue #3116 [spark] Support filter pushdown for log tables
- @fresh-borzoni: 请求 YannByron 和 luoyuxia 审查此 PR
Issue #3129 [Test] Unstable test SparkStreamingTest read: log table
- @wuchong: 抄送 Yohahaha 关注此不稳定测试问题
Issue #1519 Update documentation about the default JDK version to Java11
- @binary-signal: 网站已更新构建要求为 Maven 3.8.6 和 Java 11，请求关闭此 Issue
PR Review
PR #2836 [FLUSS-2686] Add COS filesystem support
- @leekeiabstraction: 询问是否需要为该分支添加集成测试，建议 COS 版本命名更清晰
📝 新建 Issue/PR
Issues
- #3129 [Test] Unstable test SparkStreamingTest read: log table @wuchong component=connector/spark
- #3128 [website] Move blog content to a separate repository @wuchong component=website
- #3127 [test] Unstable test FlussAdminITCase.testDynamicConfigs @app/github-actions
- #3126 Extend the API to support KvScan @wuchong
- #3125 Implement Server-Side KvScan @wuchong
- #3124 Introduce Protobuf definitions for RPC @wuchong
- #3122 [spark] Make LakeSplit extend Serializable to simplify Spark serialization @YannByron
Pull Requests
- #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
- #3123 [spark] Make LakeSplit extend Serializable to simplify Spark serialization @YannByron
✅ 关闭 Issue/PR
已关闭 Issues
- #3128 [website] Move blog content to a separate repository @wuchong component=website
- #3124 Introduce Protobuf definitions for RPC @wuchong
- #3049 Introduce `netty.server.max-request-size` to limit the request size @loserwang1024 version: 0.9.1
- #2908 Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled @luoyuxia
- #2673 [spark] to support map type @YannByron
- #2667 [spark] to support scala2.13 @YannByron
已合并 PRs
- #3130 [website] Move blog content to a separate repository "apache/fluss-blog" @wuchong
- #3108 [server][netty] Introduce netty.server.max-request-size to limit the request size (#3050) @wuchong
- #3041 [spark] support scala 2.13 @YannByron
- #2976 Introduce RPC Layer for KV Scan @polyzos
- #2924 [server] Allow enabling lakehouse on tables created before cluster-level lakehouse is enabled @luoyuxia priority=critical
- #2740 [spark] support map type @YannByron