[jira] [Closed] (FLINK-25635) Using sql client create hive catalog throw exception

["Jing Zhang (Jira)" <ji...@apache.org>]

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

Jing Zhang closed FLINK-25635.
------------------------------
    Resolution: Not A Bug

> Using sql client create hive catalog throw exception
> ----------------------------------------------------
>
>                 Key: FLINK-25635
>                 URL: https://issues.apache.org/jira/browse/FLINK-25635
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Hive, Table SQL / Ecosystem
>    Affects Versions: 1.14.0, 1.15.0
>            Reporter: dalongliu
>            Priority: Minor
>             Fix For: 1.15.0
>
>         Attachments: image-2022-01-17-16-09-28-364.png, image-2022-01-17-16-13-07-674.png, image-2022-01-17-16-59-25-147.png, image-2022-01-17-17-00-18-160.png, image-2022-01-17-17-00-41-223.png, screenshot-1.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)