方勇老师说的没错。我们在文档里面也加了如何配置 hiveserver2 endpoint 的文档[1]
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hiveserver2/#setting-up Shammon FY <zjur...@gmail.com> 于2023年3月27日周一 08:41写道： > Hi > > > 如果要启动hiveserver2协议的gateway，需要将jar包flink-connector-hive_${scala.binary.version}放入到gateway的lib目录 > > Best, > Shammon FY > > > On Sun, Mar 26, 2023 at 12:07 PM guanyq <dlgua...@163.com> wrote: > > > 本地启动了flink及hive在启动sql gateway时有以下异常，请问还需要其他什么操作么 > > ./bin/sql-gateway.sh start-foreground > > -Dsql-gateway.endpoint.type=hiveserver2 > > > -Dsql-gateway.endpoint.hiveserver2.catalog.hive-conf-dir=/usr/local/app/apache-hive-3.1.2-bin/conf > > > > > > 异常信息 > > > > Available factory identifiers are: > > rest > > at > > > org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:545) > > ~[flink-table-api-java-uber-1.16.0.jar:1.16.0] > > at > > > org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactoryUtils.createSqlGatewayEndpoint(SqlGatewayEndpointFactoryUtils.java:65) > > ~[flink-table-api-java-uber-1.16.0.jar:1.16.0] > > at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:72) > > [flink-sql-gateway-1.16.0.jar:1.16.0] > > at > > > org.apache.flink.table.gateway.SqlGateway.startSqlGateway(SqlGateway.java:118) > > [flink-sql-gateway-1.16.0.jar:1.16.0] > > at org.apache.flink.table.gateway.SqlGateway.main(SqlGateway.java:98) > > [flink-sql-gateway-1.16.0.jar:1.16.0] > > Exception in thread "main" > > org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to > > start the endpoints. > > at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:79) > > at > > > org.apache.flink.table.gateway.SqlGateway.startSqlGateway(SqlGateway.java:118) > > at org.apache.flink.table.gateway.SqlGateway.main(SqlGateway.java:98) > > Caused by: org.apache.flink.table.api.ValidationException: Could not find > > any factory for identifier 'hiveserver2' that implements > > 'SqlGatewayEndpointFactory' in the classpath. > > Available factory identifiers are: > > rest > > at > > > org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:545) > > at > > > org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactoryUtils.createSqlGatewayEndpoint(SqlGatewayEndpointFactoryUtils.java:65) > > at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:72) > > ... 2 more > > > > >
