📝 0 新 Issues
✅ 1 关闭
✨ 2 新 PRs
🎉 4 合并
⚠️ 重点关注
- ⚠️ Issue #3483 commitLakeTableSnapshot 在 dropTable 后写入过时快照路径，导致分层存储管道永久卡住
💬 Issue/PR 动态
Issue 讨论
Issue #3483 commitLakeTableSnapshot writes stale snapshot path after dropTable, leaving the tiering pipeline permanently stuck
- @luoyuxia: 建议分两个 PR 处理竞争条件，其中一个方案是让 lake committer 检查 table ID。
Issue #3465 [test] Unstable test FlinkUnionReadPrimaryKeyTableITCase.testUnionReadInStreamMode
- @github-actions[bot]: 报告测试失败：bucket 未同步，导致 testUnionReadInStreamMode 运行超时。
Issue #3447 [client] Enum conversion functionality for typed writer/reader
- @fresh-borzoni: 请求 rebase/cherry-pick 解决冲突，并询问 mappedName 变量是否真的需要。
- @VladBanar: 同意删除不必要的 mappedName，并已解决合并冲突。
Issue #3415 Add per-scanner dimension for scanner metrics
- @charlesdong1991: 因下周休假，将 Issue 移交给其他人处理。
PR Review
PR #3509 [lake/hudi] Introduce Hudi LakeCommitter
- @Copilot: 指出 commit() 忽略了 compaction statuses 可能导致数据丢失，建议快速失败机制。
PR #3507 [lake/hudi] Introduce Hudi lake writer support for tiering tables
- @Copilot: 指出 lastPendingInstant 状态判断风险、validateLength 校验弱点及 RecordWriteBuffer 错误处理问题。
- @luoyuxia: 指出未使用的变量、无限等待的超时设置风险以及 CkpMetadata 的序列化问题。
PR #3506 [flink] Refactor tiering split assertions to ignore round metadata
- @Copilot: 建议恢复构造函数中的字段验证逻辑，移除可能导致运行时错误的断言。
PR #3447 [client] Enum conversion functionality for typed writer/reader
- @VladBanar: 增加了往返测试、小写枚举支持和数组测试覆盖。
📝 新建 Issue/PR
Issues
暂无
Pull Requests
- #3509 [lake/hudi] Introduce Hudi LakeCommitter @fhan688
- #3508 [CVE][fs] Exclude vulnerable jetty-http dependency @morazow
✅ 关闭 Issue/PR
已关闭 Issues
- #3439 [client] Add support of column aliasing for PojoConverter @VladBanar
已合并 PRs
- #3507 [lake/hudi] Introduce Hudi lake writer support for tiering tables @fhan688
- #3506 [flink] Refactor tiering split assertions to ignore round metadata @luoyuxia
- #3503 [lake/hudi] Introduce tag field for tiering splits @fhan688
- #3444 [client] Add support of column aliasing for PojoConverter @VladBanar