🌊 Fluss 每日动态

📅 2026-05-20

🔗 apache/fluss

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

🔥 核心要点

⚠️ 重点关注

💬 Issue/PR 动态

Issue 讨论

Issue #3131 [server] Resume deletions off startup via scheduled event

  • @wattt3: 请求 Review 并在后续感谢审查，表示已处理评论意见

Issue #2836 [FLUSS-2686] Add COS filesystem support

  • @simonsssu: 表示已进行手动测试
  • @luoyuxia: 详细审查 COS 实现，提出 5 个问题：STS token 作用域过宽、SDK 重复依赖、文档类名/环境变量错误、token 有效期不一致、尾部空格

Issue #2879 $binlog source may fail on interleaved updates from multiple log splits

  • @luoyuxia: 通过 PR #3149 关闭此问题

Issue #2982 [test] Unstable test CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit

  • @github-actions[bot]: 报告测试失败：testDeleteOutOfSyncReplicaLogAfterCommit 出现 AssertionError

Issue #2593 [lake/iceberg] Support ADD COLUMN schema evolution for Iceberg lake catalog

  • @polygos: 表示会尝试用 Co-Pilot 审查，下周亲自查看，感谢贡献

Issue #3355 [flink] Preserve log-only source restore mode

  • @luoyuxia: 请求帮助审查，后回复已处理评论意见

Issue #3356 [flink] Include lake reader in source metrics and correct max timestamp lag semantics

  • @zuston: 通知相关人员进行审查

PR Review

PR #3355 [flink] Preserve log-only source restore mode

  • @loserwang1024: 讨论 enumerator 创建逻辑：状态less重启与有状态恢复时 lake splits 的生成时机
  • @luoyuxia: 重构修复方案：使用 checkpointTriggeredBefore 标志，并将 lake split 初始化改为同步调用
  • @fresh-borzoni: 建议将 null 状态标准化逻辑放在 restoreEnumerator() 而非 generateHybridLakeFlussSplits()

PR #3131 [server] Resume deletions off startup via scheduled event

  • @LiebingYu: 提出多处修改建议：5秒间隔过于激进建议改为6小时、需要优雅关闭、保留部分代码
  • @wattt3: 已改用 ExecutorUtils.gracefulShutdown() 实现优雅关闭

PR #3174 [server] Throttle auto-partition drop to protect coordinator queue

  • @Copilot: 自动审查提出多个问题：删除分区计数不准确、HashMap 迭代顺序不确定导致不公平、跨线程读取未同步、配置键引用错误、预算单位不匹配等
  • @platinumhamburg: 询问 dropBudgetThisRound 变量及新增变量的必要性

PR #2593 [lake/iceberg] Support ADD COLUMN schema evolution for Iceberg lake catalog

  • @Copilot: 自动审查指出字段 ID 从 0 开始可能与现有 schema 冲突；异常消息措辞需改进

📝 新建 Issue/PR

Issues

Pull Requests

✅ 关闭 Issue/PR

已关闭 Issues

已合并 PRs