开发者社区> 问答> 正文

flink sql 客户端连接hive 3.1.0出现connection refused异常

flink版本1.12.2 ,在交互式界面执行flink sql 连接hive操作时,出现连接拒绝异常,内容如下: Flink SQL> use catalog myhive;

Flink SQL> show tables; dim_kcl_customer_source_1h_all mytest

Flink SQL> select * from dim_kcl_customer_source_1h_all limit 10; 2021-04-14 10:22:24,451 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.hook.proto.base-directory does not exist 2021-04-14 10:22:24,452 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.strict.managed.tables does not exist 2021-04-14 10:22:24,452 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.stats.fetch.partition.stats does not exist 2021-04-14 10:22:24,452 WARN org.apache.hadoop.hive.conf.HiveConf [] - HiveConf of name hive.heapsize does not exist 2021-04-14 10:22:24,466 INFO org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Trying to connect to metastore with URI thrift://test-hadoop002:9083 2021-04-14 10:22:24,467 INFO org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Opened a connection to metastore, current connections: 2 2021-04-14 10:22:24,468 INFO org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Connected to metastore. 2021-04-14 10:22:24,468 INFO org.apache.hadoop.hive.metastore.RetryingMetaStoreClient [] - RetryingMetaStoreClient proxy=class org.apache.hadoop.hive.metastore.HiveMetaStoreClient ugi=hadoop (auth:SIMPLE) retries=24 delay=5 lifetime=0 2021-04-14 10:22:24,609 INFO org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Closed a connection to metastore, current connections: 1 2021-04-14 10:22:25,057 WARN org.apache.hadoop.hdfs.shortcircuit.DomainSocketFactory [] - The short-circuit local reads feature cannot be used because libhadoop cannot be loaded. 2021-04-14 10:22:25,235 INFO org.apache.hadoop.mapred.FileInputFormat [] - Total input files to process : 1 [ERROR] Could not execute SQL statement. Reason:java.net.ConnectException: Connection refused

*表能查出来,执行sql语句时遇到拒绝连接,在hive里面执行同样的sql能查到数据,请问一下这块出现的问题是什么原因导致的呢。该如何排查**来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-05 22:16:00 1722 0
1 条回答
写回答
取消 提交回答
  • 你好, 可以看一下SQL client的日志,里面应该有更详细的堆栈信息。*来自志愿者整理的flink

    2021-12-06 11:39:09
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Hive Bucketing in Apache Spark 立即下载
spark替代HIVE实现ETL作业 立即下载
2019大数据技术公开课第五季—Hive迁移到MaxCompute最佳实践 立即下载