EricZ
EricZ
@Zouxxyy @JingsongLi Please have a review.
> Can we just set `new DataField(6, "create_time", new TimestampType(false, 3))` to `new DataField(6, "create_time", new TimestampType(3))` and return null directly? @JingsongLi Okay, I push a new commit with your...
> @eric666666 good new! @JingsongLi I forgot check format violations,and I just repaired it, please trigger workflows again.
> Please fix `TagsTableTest.testTagsTable`. @JingsongLi Okay, next time I will pay attention to running the test class locally first.
> I haven't reproduced it. Can you provide more detailed steps to reproduce it, is the tag written in spark? I find the reson. The tag is created by flink...
If you want 1->1 mappingļ¼Paimon's bucket number should bigger than kafka partitions, and their should be shuffle by kafka partition id. I think paimon already can implement your thoughts. Here...
@tsreaper @JingsongLi Please have a look.
> @tsreaper @JingsongLi Please have a look. I remove the condition, to fix the problem. But I look at the code, the conditions here seem to be intended, so I...
> Flink 1.14? No, Flink 1.18.1
It may happen when you change the bucket number but have not overwrite table first.