[jira] [Updated] (FLINK-27116) Supports read Hive table partitioned by decimal

["luoyuxia (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-27116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

luoyuxia updated FLINK-27116:
-----------------------------
    Summary: Supports read Hive table partitioned by decimal  (was: Supports Hive table partitioned by decimal)

> Supports read Hive table partitioned by decimal
> -----------------------------------------------
>
>                 Key: FLINK-27116
>                 URL: https://issues.apache.org/jira/browse/FLINK-27116
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Hive
>            Reporter: luoyuxia
>            Priority: Major
>
> 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
> {code:java}
> @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);
> } {code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)