Hi, everyone

I'm working on the issue of #4004, and I found the original parameters from
RewriteFileIndexProcedure to Flink source code don't contain a partition
field. This example has additional partition field parameters of dt and hh,
so an error occurred.
I think flink-table-common and flink-table-api need to be modified to
rewrite file index with partitions, but that's not paimon's job. Perhaps
the input can be changed?


https://github.com/apache/paimon/issues/4004

Reply via email to