[jira] [Closed] (FLINK-40025) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table

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

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

Stepan Stepanishchev closed FLINK-40025.
----------------------------------------
    Resolution: Duplicate

> HiveCatalog throws TableNotPartitionedException on partitioned non-hive table
> -----------------------------------------------------------------------------
>
>                 Key: FLINK-40025
>                 URL: https://issues.apache.org/jira/browse/FLINK-40025
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Hive
>            Reporter: Stepan Stepanishchev
>            Priority: Major
>
> If we try to store the non-hive partitioned table (e.g. 'connector'='filesystem') using HiveCatalog, then the table metadata is stored inside hive metastore without information about partition keys. If we will try to invoke operation that requires partitioned table we get TableNotPartitionedException.
> How to reproduce:
> CREATE CATALOG myhive
> WITH (
> 'type' = 'hive',
> 'hive-conf-dir' = '/opt/client/Hive/config',
> 'hive-version' = '3.1.0'
> );
> USE CATALOG myhive;
> create table test_table(
> uuid varchar(20),
> name varchar(10),
> dt varchar(20)
> )
> PARTITIONED BY (dt)
> with (
> 'connector' = 'filesystem',
> 'path' = 'hdfs://hacluster/tmp/test_table',
> 'format'= 'csv'
> );
> SHOW PARTITIONS test_table;
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.table.catalog.exceptions.TableNotPartitionedException: Table default.test_filesystem in catalog MyCatalog is not partitioned.
>  
> SHOW PARTITIONS should not throw TableNotPartitionedException for a table created with PARTITIONED BY. If no partition instances are registered in the catalog, returning an empty result would be acceptable. Moreover, default catalog will also return an empty result for filesystem connector. So should HiveCatalog.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)