You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Ryan Goldenberg (Jira)" <ji...@apache.org> on 2024/05/02 23:22:00 UTC
[jira] [Created] (FLINK-35286) Cannot discover Hive connector outside Hive catalog
Ryan Goldenberg created FLINK-35286:
---------------------------------------
Summary: Cannot discover Hive connector outside Hive catalog
Key: FLINK-35286
URL: https://issues.apache.org/jira/browse/FLINK-35286
Project: Flink
Issue Type: Improvement
Components: Connectors / Hive
Environment: Flink 1.18.1
Hive 2.3.9
flink-sql-connector-hive-2.3.9_2.12-1.18.1.jar
Reporter: Ryan Goldenberg
*Problem*
Referencing tables with the 'hive' connector outside of HiveCatalog gives the error
{code:java}
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath{code}
For example, when using a table created like
{code:java}
CREATE TABLE my_table LIKE hive.db.table WITH (...);{code}
Whereas the 'hive' connector is available if the table is referenced via HiveCatalog.
*Desired Behavior*
The 'hive' connector should be available for tables outside of HiveCatalog, for example in the default catalog.
*Benefits*
* Can refer to Hive tables without fully qualified path `catalog.db.table` outside of HiveCatalog, useful when it is not the only catalog or data source.
* Can modify Hive tables without changing Hive metastore or using SQL hints [here|https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/hive/hive_read_write/#reading]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)