📝 5 新 Issues
✅ 2 关闭
✨ 6 新 PRs
🎉 4 合并
🔥 核心要点
- 🎉 PR #2862 修复 Paimon lake 表分区过期未触发问题
- 🎉 PR #2454 添加 Lake Tiering 每表监控指标
- 🎉 PR #2859 支持 Flink io.tmp.dir 回退配置
- 🎉 PR #2863 回滚 Helm Chart 组件配置隔离功能
- 🐛 发现 3 个不稳定测试问题：TableChangeWatcherTest、CoordinatorEventProcessorTest、IcebergRewriteITCase
⚠️ 重点关注
- ⚠️ Issue #2869 不稳定测试 TableChangeWatcherTest.testSchemaChanges
- ⚠️ Issue #2868 不稳定测试 CoordinatorEventProcessorTest.testCreateAndDropPartition
- ⚠️ Issue #2867 不稳定测试 IcebergRewriteITCase.testLogTableCompaction
💬 Issue/PR 动态
Issue 讨论
Issue #2809 [KV] Support Full KV Scan
- @platinumhamburg: 指出三个问题：close_scanner请求无法发送、scanner生命周期未集成到leader迁移流程、客户端未处理scan错误
- @polyzos: 回复将添加future handler和错误检查，并将ScannerManager传递给ReplicaManager解决这些问题
Issue #2865 [Helm] Restructure helm chart of Fluss
- @nhuantho: 询问此方向是否正确改进 Fluss Helm chart
Issue #2581 [test] Unstable test FlussAuthorizationITCase. testInitWriter
- @Prajwal-banakar: 分析CI环境负载高导致leader选举超时，建议将等待时间从1分钟增至2分钟
Issue #2863 [Helm] Revert Chart Component Configuration Isolation (#2472)
- @swuferhong: 感谢贡献，回滚#2472因review comments未得到适当处理，需要与@affo讨论后再推进
Issue #2854 [test] Unstable test FlussAuthorizationITCase.testDeleteProducerOffsetsAuthorization
- @hemanthsavasere: 请求分配该issue，正在修复中
Issue #2683 [docs] Reintroduce the fluss-quickstart-flink Docker image
- @joebowbeer: 建议将快速启动步骤打包成 .devcontainer 配置
Issue #2472 [Helm] Chart Component Configuration Isolation
- @hsavasere: 已根据评论更新PR，请求review
Issue #2859 [lake/tiering] fallback to Flink's `io.tmp.dir` when `client.scanner.io.tmpdir` is not set
- @zuston: 请求 @luoyuxia @wuchong review
Issue #2864 [flink][test] Fix OOM when startTaskManager in FlinkMetricsITCase
- @Prajwal-banakar: CC @loserwang1024 请求review
PR Review
PR #2454 [lake/tiering] Add per-table monitoring metrics for Lake Tiering
- @Copilot: 指出注释与断言不符、建议传TieringStats.UNKNOWN替代null、注释应更新为正确描述
- @luoyuxia: 建议改为Counter类型、trace日志避免过多warning、合并字段到TieringStats、添加nullable注解
PR #2859 [lake/tiering] fallback to Flink's `io.tmp.dir` when `client.scanner.io.tmpdir` is not set
- @Copilot: 发现路径拼接问题，/fluss前的/导致父路径被忽略，应使用相对路径拼接
PR #2862 [lake/paimon] Fix partition expiration never triggered in Paimon lake table managed by Tiering Service
- @Copilot: 建议对齐注释与配置值、使用Boolean.toString替代冗余三元表达式
PR #2839 [metric] Support influxdb reporter
- @Copilot: 多处问题：SimpleEntry应改为AbstractMap、需异常处理、NPE风险、编译错误、log4j配置错误等
PR #2711 [helm] Enable metrics reporting on helm charts
- @affo: 建议优化模板定义、创建getWithOverride辅助函数、统一reporter.enabled判断逻辑
📝 新建 Issue/PR
Issues
- #2869 [test] Unstable test TableChangeWatcherTest.testSchemaChanges @app/github-actions
- #2868 [test] Unstable test CoordinatorEventProcessorTest.testCreateAndDropPartition @app/github-actions
- #2867 [test] Unstable test IcebergRewriteITCase.testLogTableCompaction @app/github-actions
- #2865 [Helm] Restructure helm chart of Fluss @nhuantho
- #2861 [lake/paimon] Partition expiration never fires in Paimon lake table when managed by Tiering Service @LiebingYu
Pull Requests
- #2872 [Lake/Iceberg] Fix testLogTableCompaction flakiness by adding compaction timeout and retry logic @hemanthsavasere
- #2871 [helm] Restructure helm chart of Fluss @nhuantho
- #2870 [Helm] Create region config for components in value file @hemanthsavasere
- #2866 Fix Unstable test FlussAuthorizationITCase.testDeleteProducerOffsetsAuthorization @hemanthsavasere
- #2864 [flink][test] Fix OOM when startTaskManager in FlinkMetricsITCase @Prajwal-banakar
- #2860 [rpc] Fixed the issue about ServerConnection retry authentication tasks were not canceled @xuzifu666
✅ 关闭 Issue/PR
已关闭 Issues
- #2861 [lake/paimon] Partition expiration never fires in Paimon lake table when managed by Tiering Service @LiebingYu
- #2440 [lake/tiering] Add Server-Level Monitoring Metrics for Lake Tiering @beryllw
已合并 PRs
- #2863 [Helm] Revert Chart Component Configuration Isolation (#2472) @affo
- #2862 [lake/paimon] Fix partition expiration never triggered in Paimon lake table managed by Tiering Service @LiebingYu
- #2859 [lake/tiering] fallback to Flink's `io.tmp.dir` when `client.scanner.io.tmpdir` is not set @zuston
- #2454 [lake/tiering] Add per-table monitoring metrics for Lake Tiering @beryllw