[FLINK-32596] The partition key will be wrong when use Flink dialect to create Hive table

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.0, 1.16.0, 1.17.0
• Component/s: Connectors / Hive
• Assignee: Vallari Rastogi
• Reporter: luoyuxia
• Created: 17/Jul/23 02:36
• Updated: 04/Mar/24 01:38

Description

Can be reproduced by the following SQL:

 

tableEnv.getConfig().setSqlDialect(SqlDialect.DEFAULT);
tableEnv.executeSql(
        "create table t1(`date` string, `geo_altitude` FLOAT) partitioned by (`date`)"
                + " with ('connector' = 'hive', 'sink.partition-commit.delay'='1 s',  'sink.partition-commit.policy.kind'='metastore,success-file')");
CatalogTable catalogTable =
        (CatalogTable) hiveCatalog.getTable(ObjectPath.fromString("default.t1"));

// the following assertion will fail
assertThat(catalogTable.getPartitionKeys().toString()).isEqualTo("[date]");