🌊 Fluss 每日动态

📅 2026-06-05

🔗 apache/fluss

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

🔥 核心要点

⚠️ 重点关注

✅ 今日无重大问题

💬 Issue/PR 动态

Issue 讨论

Issue #1467 [Client/Server] [Security] Dynamic User Creation

  • @polyzos: 关闭此 Issue,相关功能已在 #3047 中实现

PR Review

PR #3398 [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog

  • @polyzos: 建议添加端到端 SQL ITCase 测试,并讨论内置函数注册方案的安全性改进

PR #3427 [server] Keep flushedLogOffset monotonic to fix row count after failover

  • @platinumhamburg: 建议将防护检查移到 kvPreWriteBuffer.flush() 之前
  • @wattt3: 尝试移动会导致测试失败,倾向于保持现状

PR #3429 [server] Add per-task timeout for RebalanceManager to prevent indefinite blocking

  • @swuferhong: 通过 volatile 发布模式修复顺序脆弱性问题,参数将在后续引入

PR #3430 [lake/paimon] TieringSourceReader adjust to scan arrow record batch and write arrow record batch to lake

  • @fresh-borzoni: 建议检查 paimon-arrow 提供的 ArrowBundleRecords

PR #3432 [flink] Add union read support to datastream

  • @fresh-borzoni: 询问过滤器支持,并建议对 setBounded() 进行早期显式检查
  • @polyzos: 感谢反馈,已更新 PR 解决评论问题

📝 新建 Issue/PR

Issues

Pull Requests

✅ 关闭 Issue/PR

已关闭 Issues

已合并 PRs