[FLINK-27116] Supports read Hive table partitioned by decimal type

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.16.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: luoyuxia
• Reporter: luoyuxia
• Created: 07/Apr/22 09:59
• Updated: 28/Jun/22 10:56
• Resolved: 28/Jun/22 10:56

Description

When create a table partitioned by decimal, then when try to read the table, it will throw the exception "Can not convert xxx to type decimal for partition value".

It can be reproduces using the following code in HiveDialectITCase

@Test
public void t1() throws Exception {
    tableEnv.executeSql("create table src (x int,y string)");
    tableEnv.executeSql("insert into src values (1,'a'),(2,'b'),(3,'c')").await();
    // test table partitioned by decimal
    tableEnv.executeSql(
            "create table dest3 (key int, value string) partitioned by (p1 decimal(5, 2)) ");
    tableEnv.executeSql("insert overwrite dest3 partition (p1) select 1,y,100.45 from src")
            .await();
    List<Row> results = queryResult(tableEnv.sqlQuery("select * from dest3"));
    System.out.println(results);
} 

Issue Links

• links to: GitHub Pull Request #19388