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)
