Jing Ge created FLINK-28432: ------------------------------- Summary: HiveCatalogTable only support using the latest columns as partition keys Key: FLINK-28432 URL: https://issues.apache.org/jira/browse/FLINK-28432 Project: Flink Issue Type: Bug Components: Connectors / Hive Affects Versions: 1.16.0 Reporter: Jing Ge
CatalogTable.of( schema, TEST_COMMENT, PartitionKeys, BatchTableProperties); For example the schema contains 5 columns: first, second, third, fourth, fifth. It is fine if partition keys are fourth and fifth. But in case they are second and third, the created ResolvedCatalogTable will use fourth and fifth as the partition keys. -- This message was sent by Atlassian Jira (v8.20.10#820010)