🌊 Fluss 每日动态

📅 2026-05-12

🔗 apache/fluss

📝 4 新 Issues
✅ 3 关闭
✨ 6 新 PRs
🎉 5 合并

🔥 核心要点

⚠️ 重点关注

✅ 今日无重大问题

💬 Issue/PR 动态

Issue 讨论

Issue #3271 [flink] Fix COUNT(column) aggregate pushdown to reject nullable columns

  • @loserwang1024: 询问是否为 Flink SQL bug，建议提交 Flink JIRA
  • @beryllw: 确认这是 Flink Fluss SQL Source 的 bug

Issue #3302 [Bug] Avoid altering lake catalog for tables that never enabled datalake

  • @MaheshS08: 请求 luoyuxia 审核此 PR
  • @luoyuxia: 指出 CI 测试失败
  • @Prajwal-banakar: 提示 Spotless 格式化问题，建议运行 mvn spotless:apply

Issue #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery

  • @Kaixuan-Duan: 感谢 review，已处理 5 条评论并 rebase 到最新 main
  • @fresh-borzoni: 感谢更新，请求其他维护者快速审核

Issue #3306 [server] Fix flaky RebalanceManagerITCase.testBuildClusterModel

  • @Kaixuan-Duan: CI 失败原因是已知的 flaky test #2974

Issue #3256 [lake/hudi] Introduce fluss-lake-hudi module and HudiLakeStorage

  • @XuQianJin-Stars: +1 支持
  • @luoyuxia: 指出 CI 失败：代码覆盖率未达到 0.70 的最低要求

Issue #3307 Fluss binlog source fails checkpoint/savepoint with NPE in FlinkSourceEnumerator.snapshotState

  • @leonardBang: 此问题已在 #2743 中修复

Issue #2839 [metric] Support influxdb reporter

  • @swuferhong: 请求 luoyuxia 帮忙审核此 PR
  • @luoyuxia: 稍后进行快速审核

Issue #3222 [server] Respect the option of `table.log.ttl` for local segments

  • @zuston: 请求 swuferhong 帮忙审核

Issue #3308 [client] read fallback to lake when encountering OutOfRange exception

  • @zuston: 请求 luoyuxia 帮忙审核

PR Review

PR #3226 [Docs] Website Redesign

  • @michaelkoepf: 建议术语统一（cold store vs offline store），标题风格一致性问题
  • @Copilot: 指出 React import 问题、ARIA 可访问性问题、CSS 选择器问题等
  • @polyos: 对当前结果满意，请求维护者反馈

PR #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery

  • @Kaixuan-Duan: 添加 currentLocalFile 追踪已打开的 segment，处理中断时文件删除逻辑

PR #3263 [client] Refactor RemoteLogDownloader to use chunked file append instead of downloading whole log file

  • @fresh-borzoni: 指出潜在的竞态条件、volatile 使用建议、资源泄漏风险、串行化读取问题等

PR #3296 [flink] Fix batch fallback generating mixed split types for primary-key tables

  • @luoyuxia: 指出会生成没有 stop offset 的 log split，导致无法停止

PR #2839 [metric] Support influxdb reporter

  • @luoyuxia: 询问 value 是否用于 tag/label，提及 #3211 后不再过滤 tag value

PR #3308 [client] read fallback to lake when encountering OutOfRange exception

  • @zuston: 此 PR 合并后将提交优化 planning 的后续 PR

PR #3260 [spark] Add scan.max.records.per.partition config to split log table input partitions

  • @Yohahaha: 解释 startup mode 用于流式场景，批量场景将在后续 PR 重构

📝 新建 Issue/PR

Issues

Pull Requests

✅ 关闭 Issue/PR

已关闭 Issues

已合并 PRs