📝 1 新 Issues
✅ 1 关闭
✨ 2 新 PRs
🎉 1 合并
🔥 核心要点
- 🎉 PR #3550 修复了 prepareLakeTableSnapshot 错误响应中缺失 table_id 的问题
- ✨ PR #3552 为 Prometheus PushGateway 报告器添加 Basic Auth 支持，兼容 JDK 8+
- 🚀 PR #3554 将通用 tiering 类从 Flink 模块解耦，为 Spark tiering 服务做准备
- 🐛 Issue #3553 Uber-jars 中存在 Jackson 核心库与 shaded 副本并存泄漏问题
💬 Issue/PR 动态
Issue 讨论
Issue #275 [Improvement] Provide different table.log.tiered.local-segments for latest partitions and old partition.
- @fxbing: 提出为自动分区表的老分区设置不同的 local-segments 参数的建议方案，以减少本地磁盘占用
Issue #2985 [spark] Add spark tiering service
- @Yohahaha: PR 将分两阶段进行：先重构 tiering 类到 fluss-client，再实现 Spark tiering 服务
Issue #3470 [website] Use theme-aware diagram on intro page
- @Prajwal-banakar: 已创建 backport PR #3487 以支持 release-0.9 分支
Issue #3488 Support orphan database files cleanup
- @wuchong: 引用 PR #3404 的讨论，说明孤儿数据库中的孤儿文件/表的清理方案
PR Review
PR #3404 [flink-action][server][client] add orphan files cleanup action for remote storage
- @wuchong: 澄清只需清理孤儿数据库中的孤儿表/文件，而非删除整个孤儿数据库
PR #3469 [lake/tiering] Add pendingRecordLag metric for lake tiering
- @Copilot: 指出 estimatedPendingStartTimeMs 在 logEndOffset 独立更新时可能无法正确推进的问题
- @luoyuxia: 建议简化代码逻辑、重命名变量为 hasPendingLakeTieringRecords，并优化指标描述文案
PR #3471 [spark] use CamelCase in config names
- @Yohahaha: 建议将配置项命名为 scan.pollTimeout
PR #3500 [lake] Fix union read duplicating rows for non-String partition columns
- @luoyuxia: 指出 v1 版本反序列化会丢失字符串分区值，违反兼容性契约，建议保留旧逻辑并添加测试
PR #3548 [flink]Newly discovered partition read from earliest rather than scan.startup.mode
- @loserwang1024: 重构了 unassignedSplits 逻辑，说明设置 false 可保证语义一致性避免恢复时从头读取
PR #3552 [metrics][docs] Support Basic Auth for Prometheus PushGateway reporter
- @Guosmilesmile: 解释使用 java.util.Base64 替代 Prometheus 内置工厂以确保 JDK 8+ 兼容性
📝 新建 Issue/PR
Issues
- #3553 [fluss-client][ fluss-flink-*] Uber-jars leak com.fasterxml.jackson.core alongside the shaded copy @binary-signal
Pull Requests
- #3554 [tiering] Decouple common tiering class from flink module @Yohahaha
- #3552 [metrics][docs] Support Basic Auth for Prometheus PushGateway reporter @Guosmilesmile
✅ 关闭 Issue/PR
已关闭 Issues
- #3551 [server] prepareLakeTableSnapshot masks the real error on failure @fresh-borzoni
已合并 PRs
- #3550 [server] Set table_id on prepareLakeTableSnapshot error response @fresh-borzoni