You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "luoyuxia (Jira)" <ji...@apache.org> on 2022/01/17 08:15:00 UTC
[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477018#comment-17477018 ]
luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:14 AM:
------------------------------------------------------------
Brought from the Jira https://issues.apache.org/jira/browse/FLINK-23734 , the `HiveParserFactory` is no longer a ```TableFactory```, so it'll fail when try to load the ```HiveParserFactory```.
!image-2022-01-17-16-13-07-674.png|width=473,height=261!
was (Author: luoyuxia):
Brought from the Jira https://issues.apache.org/jira/browse/FLINK-23734 , the ```HiveParserFactory``` is no longer a ```TableFactory```, so it'll fail when try to load the ```HiveParserFactory```.
!image-2022-01-17-16-13-07-674.png|width=473,height=261!
> 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
> Priority: Blocker
> Fix For: 1.15.0
>
> Attachments: image-2022-01-17-16-09-28-364.png, image-2022-01-17-16-13-07-674.png
>
>
> 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)