🌊 Fluss 每日动态

📅 2026-06-26

🔗 apache/fluss

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

🔥 核心要点

⚠️ 重点关注

✅ 今日无重大问题

💬 Issue/PR 动态

Issue 讨论

Issue #3530 [test] Unstable test Flink22TableSourceBatchITCase.testCountPushDownForLogTable

  • @fxbing: 分析测试不稳定原因：测试清理与自动分区创建存在竞争，导致重建已删除的 znode，建议修改 ZooKeeper 父节点创建逻辑并跳过陈旧事件

Issue #3524 [client][filesystem] Reject client-side S3 credential options

  • @litiliu: 关闭此 issue，经重新评估这是用户配置错误而非真正问题，用户不应通过 client.fs.* 配置 S3 凭证

Issue #3515 [docs] Add Apache Polaris/Iceberg REST catalog quick-start guide

  • @MehulBatra: LGTM！感谢你的贡献，继续保持出色的工作！

Issue #3513 [docs] Add Apache Polaris/Iceberg Rest catalog quick-start guide for Fluss-Iceberg integration

    Issue #3069 [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout

    • @Prajwal-banakar: 请求 @fresh-borzoni 在有时间时帮忙 review，谢谢！

    Issue #3068 [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout config options

      Issue #3486 [security] Redact sensitive config values in startup logs

      • @litiliu: 更新了敏感密钥匹配、复用 hideSensitiveValue 处理动态配置日志、为 token 续期配置添加白名单，S3 统一匹配将作为后续优化

      Issue #2618 [docs] Add Hive Metastore catalog quick-start guide for Iceberg integ…

      • @MehulBatra: 询问是否已在本地 Docker 环境端到端验证 Fluss + Iceberg + Flink tiering 到对象存储的完整流程

      Issue #2907 [client][fix] Deduplicate insertIfNotExists lookups with same key in same batch to prevent deadlock

      • @Prajwal-banakar: 请求 @luoyuxia 帮忙 review 此 PR

      Issue #3526 [client] Reject client-side S3 credential options

      • @litiliu: 关闭此 PR，经重新评估这是用户配置错误案例，添加额外验证并非必要

      PR Review

      PR #3486 [security] Redact sensitive config values in startup logs

      • @litiliu: 保持 PR 范围聚焦于通用日志脱敏，S3 凭证检测统一将在 #3526 或后续单独处理

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

      • @qzyu999: 在 AWS ECS Fargate 上验证发现 tiering snapshot commit 失败，原因是错误处理掩盖了真实异常，S3 assumed role 凭证链未正确传递给 Hadoop S3A
      • @fresh-borzoni: 建议在 EKS/IRSA 环境配置 fs.s3a.aws.credentials.provider 使用 WebIdentityTokenCredentialsProvider 等凭证提供者
      • @qzyu999: 尝试添加 ContainerCredentialsProvider 后仍失败，问题在于错误处理掩盖了 storeLakeTableOffsetsFile 的真实异常

      PR #3529 [client] Avoid per-record AutoPartitionStrategy construction in WriterClient.doSend in log tables

      • @binary-signal: 同意建议，将在今天或明天提供修订版本

      📝 新建 Issue/PR

      Issues

      Pull Requests

      ✅ 关闭 Issue/PR

      已关闭 Issues

      已合并 PRs