📝 0 新 Issues
✅ 1 关闭
✨ 3 新 PRs
🎉 1 合并
💬 Issue/PR 动态
Issue 讨论
Issue #3278 Hudi source sortedReader and PredicateConverter
- @luoyuxia: 确认通过 PR #3501 关闭此问题
Issue #3444 [client] Add support of column aliasing for PojoConverter
- @VladBanar: 感谢 Review,已根据评论意见修改代码
Issue #3447 [client] Enum conversion functionality for typed writer/reader
- @VladBanar: 感谢 Review,已根据评论意见修改代码
Issue #3483 commitLakeTableSnapshot writes stale snapshot path after dropTable
- @Jackeyzhe: 建议将本 PR 范围限定为 case (1):当表 ID 不存在或已排队删除时拒绝 commitLakeTableSnapshot
- @binary-signal: 同意范围限定方案,case (2) 作为后续跟进,并澄清了 Lake 表在 dropTable 后的行为细节
Issue #3503 [lake/hudi] Introduce tag field for tiering splits
- @luoyuxia: 认为 tag 字段设计过于 hacky,建议使用类型化的 splitIndex 替代字符串解析方案
- @fhan688: 同意反馈意见,将引入 splitIndex 和 tieringRoundTimestamp 两个字段替代原有 tag 字段设计
PR Review
PR #3501 [lake/hudi] Support predicate pushdown
PR #3503 [lake/hudi] Introduce tag field for tiering splits
- @Copilot: 指出 skipCurrentRound 标志丢失、tag 未加入 equals/hashCode、currentTimeMillis 可能产生重复 tag 等问题
- @luoyuxia: 建议避免版本号升级因为 tiering job 是无状态的,并建议移除无意义的测试
- @fhan688: 接受建议,将保持序列化器版本为 0 并移除仅为覆盖率的测试
PR #3444 [client] Add support of column aliasing for PojoConverter
- @VladBanar: 添加重复检查、修复文档问题、增加负向测试用例
PR #3447 [client] Enum conversion functionality for typed writer/reader
- @VladBanar: 使用延迟初始化的 map、修复代码问题、增加小写枚举和数组测试
📝 新建 Issue/PR
Issues
暂无
Pull Requests
- #3505 [flink] Preserve offsets for empty tiering buckets @hutiefang76
- #3504 [docs] Make website dependency installs reproducible @hutiefang76
- #3503 [lake/hudi] Introduce tag field for tiering splits @fhan688
✅ 关闭 Issue/PR
已关闭 Issues
- #3278 Hudi source sortedReader and PredicateConverter @fhan688
已合并 PRs
- #3501 [lake/hudi] Support predicate pushdown @fhan688