Hi Jun, I'm curious why it doesn't work when represented in string? You can get the field type from the CatalogTable#getSchema(), then parse/cast the partition value to the type you want.
Best, Jark On Tue, 5 Jan 2021 at 13:43, Jun Zhang <zhangjunemail...@gmail.com> wrote: > Hello dev: > Now I encounter a problem when using the method > "Catalog#listPartitions(ObjectPath, CatalogPartitionSpec)". > I found that the partitionSpec type in CatalogPartitionSpec is > Map<String, String>, > This is no problem for hivecatalog, but my subclass of Catalog needs > precise types. For example, if the partition is of int type, passing in > "123" will not work. > So I think whether the partitionSpec field of Flink's > CatalogPartitionSpec is changed to Map<String, Object> type will be more > reasonable and universal? >
