[
https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477025#comment-17477025
]
Ingo Bürk commented on FLINK-25635:
-----------------------------------
Are you using the correct version of flink-connector-hive as well?
{quote}the HiveParserFactory is no longer a TableFactory , so it'll fail when
try to load the HiveParserFactory specific in file
"flink-connectors/flink-connector-hive/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory"{quote}
TableFactory and Factory are different interfaces – HiveParserFactory is no
longer provided as a TableFactory, so I'm not sure why it is attempted to be
loaded as such.
> 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)
