🌊 Fluss 每日动态

📅 2026-06-09

🔗 apache/fluss

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

🔥 核心要点

⚠️ 重点关注

✅ 今日无重大问题

💬 Issue/PR 动态

Issue 讨论

Issue #3174 [server] Add TableLifecycleThrottler to throttle drops in coordinator queue

  • @swuferhong: 已处理评论,将类重命名为 TableLifecycleThrottler 并引入新事件保证线程安全。

Issue #3260 [spark] Add scan.maxRecordsPerPartition config to split log table input partitions

  • @fresh-borzoni: 创建了关于 Spark 配置命名规范的后续 Issue #3462。
  • @Yohahaha: 因忙于其他优先事务未及时处理评论,感谢合并。

Issue #3383 [Flink] Kvscan flink integration

  • @polyzos: 感谢评论,已处理相关修改。

Issue #3358 [server] Respect log.* options for table

  • @zuston: 请求 fresh-borzoni 协助审查此 PR。

Issue #3456 [lake/hudi] Introduce Hudi source split planner

  • @luoyuxia: 请求 XuQianJin-Stars 协助审查此 PR。

Issue #3434 [server] Support altering auto partition num-precreate option

  • @fhan688: 请求 luoyuxia 协助审查此 PR。

Issue #3453 [server] Support altering auto partition enabled option

  • @fhan688: 请求 luoyuxia 协助审查此 PR。

Issue #3431 [server] Fix NPE when processing table registration change

  • @raoluSmile: 请求 loserwang1024 协助审查此 PR。

PR Review

PR #3174 [server] Add TableLifecycleThrottler to throttle drops in coordinator queue

  • @swuferhong: 重构逻辑至 TableLifecycleThrottler,引入 ResumeDropEvent 保证线程安全,移除了可能导致事件队列溢出的早期返回逻辑。

PR #3260 [spark] Add scan.maxRecordsPerPartition config to split log table input partitions

  • @fresh-borzoni: 创建了关于 Spark 配置命名规范的后续 Issue #3462。
  • @Yohahaha: 因忙于其他优先事务未及时处理评论,感谢合并。

PR #3400 [server] Add Cluster Health API implementation

  • @wuchong: 建议移除 grace period 逻辑以避免升级时的死时间,并询问 Coordinator 地址变更的影响。

PR #3420 [lake/tiering] Support reporting watermark to Paimon snapshot

  • @Copilot: 指出日志占位符参数顺序错误、接口新增方法破坏兼容性以及注释语法问题。

PR #3424 [docs] add docs to integrate Fluss + Iceberg via Flink with AWS Glue and Hive

  • @Copilot: 指出 Glue ARN 模式错误、Iceberg S3 配置说明缺失以及专有名词大小写规范问题。

PR #3458 [server] Allow altering datalake auto-compaction before lake enabled

  • @luoyuxia: 质疑为何在 datalake 启用时禁止修改配置,建议移除该限制。
  • @wzx140: 同意观点,表示没有理由阻止此修改,将更新逻辑移除限制。

📝 新建 Issue/PR

Issues

Pull Requests

✅ 关闭 Issue/PR

已关闭 Issues

已合并 PRs