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
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。