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能查到数据,请问一下这块出现的问题是什么原因导致的呢。该如何排查*

回复