📝 4 新 Issues
✅ 0 关闭
✨ 5 新 PRs
🎉 0 合并
⚠️ 重点关注
- ⚠️ Issue #3228 长时间中断后恢复读取流日志表可能抛出 OutOfRangeException
- ⚠️ Issue #3188 测试 CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup 不稳定
💬 Issue/PR 动态
Issue 讨论
Issue #2371 Tiering may stuck for first row merge engine table
- @Kaixuan-Duan: 询问是否仍在处理该问题，表示愿意帮忙协作
- @luoyuxia: cc zuston 请关注此问题
- @zuston: 感谢帮助，请继续推进
Issue #3084 Flink log table consumer threw an out-of-range offset exception
Issue #3188 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup
- @github-actions[bot]: 报告测试失败：AssertionFailedError
Issue #3224 Recovery failure when the tablet server shuts down due to 'No space left on device'
- @zuston: cc 相关人员关注此磁盘空间恢复失败问题
Issue #3227 [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1)
- @luoyuxia: 指出该 PR 与 #2725 重复
- @Kaixuan-Duan: 抱歉未注意到已有 PR 指向该问题
Issue #3230 Streaming union read from the lake and Fluss log table using a specified offset timestamp
Issue #3233 [server] Support altering table.log.ttl table option
- @Kaixuan-Duan: 已根据反馈修改，请审查
Issue #3236 [flink] union read from lake with startup timestamp filter
- @binary-signal: 说明有主键表使用起始偏移时间戳仍有效
PR Review
PR #2725 [spark] Fix empty projection issue in Spark batch read to avoid Arrow metadata errors with COUNT(*)/COUNT(1)
- @Copilot: 建议更新方法注释匹配实际支持范围，增加 COUNT(1) 测试用例
PR #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery
- @fresh-borzoni: 详细审查异步下载重试逻辑、Future.cancel 中断传播、线程安全等问题
PR #3200 [server] Support configurable time partition format for auto-partitioned tables
- @Copilot: 建议验证时间格式输出字符约束，文档需说明允许的字符集
PR #3208 [flink] Fix batch query on empty datalake-enabled table to return 0 rows instead of failing
- @luoyuxia: 质疑返回空列表会丢失实际数据，建议回退到 Fluss-only 分片
- @matrixsparse: 已更新为回退到 Fluss-only 分片生成逻辑
- @fresh-borzoni: 建议添加 info 日志便于追踪
PR #3217 [website] Publish Apache Fluss 0.9.1-incubating
- @wuchong: 建议将措辞改为 minor release 而非 patch update
PR #3227 [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1)
- @Yohahaha: 询问有过滤器时的行为
- @Kaixuan-Duan: 解释 COUNT(*) 带过滤器不会走空投影路径，行为正确
PR #3233 [server] Support altering table.log.ttl table option
- @Copilot: 建议移除 @VisibleForTesting 注解，优化日志级别为 DEBUG，避免硬编码默认 TTL
📝 新建 Issue/PR
Issues
- #3235 [Umbrella] Umbrella issue for System Tables @gyang94
- #3231 Support alter table.log.ttl @Kaixuan-Duan
- #3230 Streaming union read from the lake and Fluss log table using a specified offset timestamp @zuston
- #3228 Possible OutOfRangeException when reading the stream log table after resuming from a long interruption @zuston
Pull Requests
- #3236 [flink] union read from lake with startup timestamp filter @zuston
- #3234 [server] table buckets system view @gyang94
- #3233 [server] Support altering table.log.ttl table option @Kaixuan-Duan
- #3232 [server] Add request queue size metric per processor @zuston
- #3229 [server] Add metrics of log startOffset @zuston
✅ 关闭 Issue/PR
已关闭 Issues
暂无
已合并 PRs
暂无