flink 
14.3,环境中已经有HADOOP_CLASSPATH变量,flink的lib文件夹也有flink-sql-connector-hive-3.1.2_2.11-1.14.3.jar。
在sql-client中查询kafka表没问题,查询hive表报错如下:
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.hadoop.mapred.JobConf




可是已经在启动sql-client.sh时通过-l参数导入了hadoop-mapreduce-client-core-3.2.2.jar包了,还是一样报错。
请问如何解决
















--

kingdomad

Reply via email to