📝 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 #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
- #3462 [spark] use CamelCase in spark configs @fresh-borzoni
- #3461 [ui] Support Fluss UI for database and table management @litiliu
- #3460 [test] Unstable test RemoteLogDownloaderTest.testPrefetchNum @app/github-actions
- #3457 Refactor the jittered partition creation logic in AutoPartitionManager to TableLifecycleThrottler @swuferhong
Pull Requests
- #3459 [client][server] Support adding aggregation columns @wzx140
- #3458 [server] Allow altering datalake auto-compaction before lake enabled @wzx140
✅ 关闭 Issue/PR
已关闭 Issues
- #3437 [UT] ComponentClassLoaderTest fails when java.io.tmpdir contains dots @litiliu
- #3215 [spark] Add config to split input partition by input size @Yohahaha
已合并 PRs
- #3450 [test] Fix ComponentClassLoaderTest tmpdir path handling @litiliu
- #3448 [metrics] Fix typo in scanner metric name @charlesdong1991
- #3438 [docs] Update README engine support @wangzhigang1999
- #3434 [server] Support altering auto partition num-precreate option @fhan688
- #3260 [spark] Add scan.maxRecordsPerPartition config to split log table input partitions @Yohahaha