Jingsong Lee created FLINK-14381: ------------------------------------ Summary: Partition field names should be got from CatalogTable instead of source/sink Key: FLINK-14381 URL: https://issues.apache.org/jira/browse/FLINK-14381 Project: Flink Issue Type: Sub-task Components: Table SQL / API, Table SQL / Planner Reporter: Jingsong Lee Fix For: 1.10.0
Now PartitionableTableSource and PartitionableTableSink have "getPartitionFieldNames" method, this should be removed, and planner rules should get it from CatalogManager. The partition field names are the information of Table, source/sink should only be fed with such information but not get them out of it. -- This message was sent by Atlassian Jira (v8.3.4#803005)