dalongliu created FLINK-25635:
---------------------------------
Summary: Using sql client create hive catalog throw exception
Key: FLINK-25635
URL: https://issues.apache.org/jira/browse/FLINK-25635
Project: Flink
Issue Type: New Feature
Components: Connectors / Hive, Table SQL / Ecosystem
Affects Versions: 1.14.0, 1.15.0
Reporter: dalongliu
Fix For: 1.15.0
CREATE CATALOG hive WITH('type' = 'hive',
'hive-conf-dir'='/usr/local/hive/conf');
[ERROR] Could not execute SQL statement. Reason:
java.util.ServiceConfigurationError:
org.apache.flink.table.factories.TableFactory: Provider
org.apache.flink.table.planner.delegation.hive.HiveParserFactory not a subtype
at java.util.ServiceLoader.fail(ServiceLoader.java:239)
at java.util.ServiceLoader.access$300(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.nextService(ServiceLoader.java:376)
at java.util.ServiceLoader$LazyIterator.next(ServiceLoader.java:404)
at java.util.ServiceLoader$1.next(ServiceLoader.java:480)
at java.util.Iterator.forEachRemaining(Iterator.java:116)
at
org.apache.flink.table.factories.TableFactoryService.discoverFactories(TableFactoryService.java:208)
at
org.apache.flink.table.factories.TableFactoryService.findSingleInternal(TableFactoryService.java:153)
at
org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.java:123)
at
org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:264)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1292)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1122)
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209)
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209)
at
org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:625)
at
org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:447)
at
org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332)
at java.util.Optional.ifPresent(Optional.java:159)
at
org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325)
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297)
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221)
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
