📝 4 新 Issues
✅ 4 关闭
✨ 5 新 PRs
🎉 6 合并
🔥 核心要点
- 🎉 PR #2857 修复 alterClusterConfigs 返回误导性 UnknownServerException 的问题
- 🎉 PR #2827 修复幂等写入器在响应丢失时进入无限重试循环的 bug
- 🎉 PR #2506 Helm chart 支持 SASL 认证配置
- 🎉 PR #2502 支持 Protobuf 和 RPC 层的 Predicate 功能
- ✨ PR #2875 新增 VARIANT 数据类型支持功能开发中
💬 Issue/PR 动态
Issue 讨论
Issue #2809 [KV] Support Full KV Scan
- @platinumhamburg: 提出三个潜在问题：scanner 无法发送 close_scanner 请求、生命周期未集成迁移流程、客户端未处理 scan 错误
Issue #2676 [spark] remove the warning info when insert data to a new partition
- @hemanthsavasere: 请求分配该 issue 以便参与贡献
Issue #2724 [spark] Empty projection in batch read throws Invalid metadata length with COUNT(*)/COUNT(1)
- @hemanthsavasere: 请求分配该 issue 以便参与贡献
Issue #2865 [Helm] Restructure helm chart of Fluss
- @affo: 支持 nhuantho 的 PR 提议，表示会跟进相关评论
Issue #2870 [Helm] Create region config for components in value file
- @nhuantho: 说明该 PR 可以解决问题 #2870
- @affo: 建议可以继续推进该 PR
Issue #2871 [helm] Restructure helm chart of Fluss
- @nhuantho: 解释 Helm schema 注解、工具选择和 value 定义标准的考虑
- @affo: 建议使用 Python 3.12，添加 requirements.txt，并推荐 helm-docs 工具
Issue #2850 [docs] Update s3.region in quickstart docs of flink and lakehouse
- @nhuantho: 请求 review 并添加了测试截图
- @leekeiabstraction: 建议在 PR 描述中添加测试详情，记录设置 region 参数后的日志输出
Issue #2878 [docs] add trending tag
- @MehulBatra: 添加了 trending 标签的截图展示
Issue #2827 [client] Fix idempotent writer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed
- @LiebingYu: 根据 review 意见完成了代码更新
Issue #2876 Fixing issue with row update not working for PK table:
- @vamossagar12: 创建 PR 并请求 review
Issue #2881 [lake/iceberg] Support snapshot expiration for lake tables
- @vamossagar12: 请求 luoyuxia 进行 review
Issue #2883 [hotfix] Still do remove server tag if tablet server not exist
- @zcoo: 请求 swuferhong 再次审查
PR Review
PR #2827 [client] Fix idempotent writer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed
- @wuchong: 建议重构条件判断顺序，先验证有效完成、再尝试重试、最后失败，使逻辑更清晰
PR #2880 [flink] Fix $binlog update pairing across log splits
- @Copilot: 指出 UPDATE_BEFORE 处理可能静默覆盖缓冲记录导致 binlog 输出错误，建议检测并抛异常
PR #2871 [helm] Restructure helm chart of Fluss
- @affo: 建议使用 Python 3.12、添加 requirements.txt、重命名验证步骤名称
- @nhuantho: 解释验证脚本的用途，说明更新 Helm 时需要解释 schema 变更
PR #2852 [server] Fix get table count of database.
- @wuchong: 指出双重 I/O 开销问题，建议批量获取统计信息并行化以减少执行时间
PR #2881 [lake/iceberg] Support snapshot expiration for lake tables
- @Copilot: 指出测试依赖 Thread.sleep 存在时间敏感性，建议使用确定性条件避免 CI 不稳定
PR #2883 [hotfix] Still do remove server tag if tablet server not exist
- @swuferhong: 指出测试未覆盖 serverTag 存在但服务器已离线的情况，建议补充该测试用例
PR #2711 [helm] Enable metrics reporting on helm charts
- @morazow: 添加验证函数处理 reporter 端口缺失和端口覆盖的失败情况
📝 新建 Issue/PR
Issues
- #2882 [hotfix] Still do remove server tag if tablet server not exist @zcoo
- #2879 $binlog source may fail on interleaved updates from multiple log splits @luoyuxia
- #2874 [test] Unstable test Flink119TableSourceITCase.testLookupInsertIfNotExists @app/github-actions
- #2873 [Feature] Support for VARIANT data type @XuQianJin-Stars
Pull Requests
- #2883 [hotfix] Still do remove server tag if tablet server not exist @zcoo
- #2881 [lake/iceberg] Support snapshot expiration for lake tables @vamossagar12
- #2880 [flink] Fix $binlog update pairing across log splits @luoyuxia
- #2876 Fixing issue with row update not working for PK table: @vamossagar12
- #2875 [Feature] Support for VARIANT data type @XuQianJin-Stars
✅ 关闭 Issue/PR
已关闭 Issues
- #2856 [server] Admin.alterClusterConfigs() returns UnknownServerException instead of ConfigException on validation failure @LiebingYu
- #2826 [client] Idempotent producer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed @LiebingYu
- #2503 [helm] Enable SASL authentication configurations @morazow
- #2496 [FIP-10] Introduce Predicate in Protobuf and RPC Layer @polyzos
已合并 PRs
- #2878 [docs] add trending tag @MehulBatra
- #2857 [server] Register ConfigException in Errors to fix misleading UnknownServerException from alterClusterConfigs @LiebingYu
- #2827 [client] Fix idempotent writer enters infinite retry loop with OutOfOrderSequenceException when response is lost but subsequent batches succeed @LiebingYu
- #2810 [fix] fix serialize modifiedTime field in TableRegistrationJsonSerde @gyang94
- #2506 [helm] Enable SASL authentication configurations @morazow
- #2502 Support Protobuf and RPC for Predicates @polyzos