[FLINK-25635] Using sql client create hive catalog throw exception

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Bug
• Affects Version/s: 1.14.0, 1.15.0
• Fix Version/s: 1.15.0
• Component/s: Connectors / Hive, Table SQL / Ecosystem
• Assignee: Unassigned
• Reporter: dalongliu
• Created: 13/Jan/22 04:00
• Updated: 02/Apr/22 09:57
• Resolved: 02/Apr/22 09:57

Description

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)