Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactory
原来的导包依赖是:
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-hive_2.12</artifactId>
<version>${flink.version}</version>
</dependency>-->
后面上网查了:https://blog.csdn.net/Chenftli/article/details/125235160
尝试将导包依赖修改为:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-sql-connector-hive-2.3.9_2.12</artifactId>
<version>1.16.0</version>
<scope>provided</scope>
可以正常跑通。