开发者社区> 问答> 正文

flink1.12 SQL Client 报错

使用 SQL Client,进行hive查询时报错:  命名有了flink-connector-hive_2.11-1.12.0.jar,还是报java.lang.ClassNotFoundException: org.apache.flink.connectors.hive.HiveSource  麻烦看一下 

报错信息: 

Flink SQL> select count(*) from zxw_test_1225_01;  2020-12-30 16:20:42,518 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.spark.client.submit.timeout.interval does not exist  2020-12-30 16:20:42,519 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.support.sql11.reserved.keywords does not exist  2020-12-30 16:20:42,520 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.spark.client.rpc.server.address.use.ip does not exist  2020-12-30 16:20:42,520 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.enforce.bucketing does not exist  2020-12-30 16:20:42,520 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.server2.enable.impersonation does not exist  2020-12-30 16:20:42,520 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.run.timeout.seconds does not exist  2020-12-30 16:20:43,065 WARN org.apache.hadoop.hdfs.shortcircuit.DomainSocketFactory [] - The short-circuit local reads feature cannot be used because libhadoop cannot be loaded.  2020-12-30 16:20:43,245 INFO org.apache.hadoop.mapred.FileInputFormat [] - Total input files to process : 24  [ERROR] Could not execute SQL statement. Reason:  java.lang.ClassNotFoundException: org.apache.flink.connectors.hive.HiveSource 

lib包: 

tree lib 

lib  ├── flink-connector-hive_2.11-1.12.0.jar  ├── flink-csv-1.12.0.jar  ├── flink-dist_2.11-1.12.0.jar  ├── flink-hadoop-compatibility_2.11-1.12.0.jar  ├── flink-json-1.12.0.jar  ├── flink-shaded-hadoop-2-uber-2.8.3-10.0.jar  ├── flink-shaded-zookeeper-3.4.14.jar  ├── flink-table_2.11-1.12.0.jar  ├── flink-table-blink_2.11-1.12.0.jar  ├── hive-exec-2.3.4.jar  ├── log4j-1.2-api-2.12.1.jar  ├── log4j-api-2.12.1.jar  ├── log4j-core-2.12.1.jar  └── log4j-slf4j-impl-2.12.1.jar*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 15:04:10 921 0
1 条回答
写回答
取消 提交回答
  • 你在启动之后才把 jar 包放进去的吗,重启下 SQL Client 试试?*来自志愿者整理的FLINK邮件归档

    2021-12-02 15:54:11
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载