- 117
- 0
问题描述
执行spark-submit [pyspark脚本].py,执行到SQL语句时报连接失败错误,在配置使用远程HDFS的情况下依然尝试连接本地的9000端口,根据此错误信息的官网介绍第五段,9000端口是HDFS端口。
(仅摘录重要信息):
Traceback (most recent call last):
File "/root/try.py", line 15, in <module>
coap = spark.sql("select * from [表名] limit 5").collect()
py4j.protocol.Py4JJavaError:
An error occurred while calling o42.collectToPython.
: java.net.ConnectException:
Call From master/127.0.1.1 to master:9000 failed on connection
问题出现的环境背景及自己尝试过哪些方法
按照spark官网Hive Tables文档第二段内容,将core-site.xml文件放在了$SPARK_HOME/conf目录下。其中有配置信息:
<property>
<name>fs.defaultFS</name>
<value>hdfs://192.168.0.24:9000/</value>
</property>
发现不管用之后,又根据官网文档Inheriting Hadoop Cluster Configuration的指南,把同文件夹下的spark-env.sh文件中HADOOP_CONF_DIR环境变量的值指向了$SPARK_HOME/conf的绝对路径(文件里写的并不是$SPARK_HOME),然而依然不管用。
spark-defaults.conf内也没有可能覆盖此项的配置,pyspark脚本里更没有。
- 共 0 条
- 全部回答
-
棉花糖味的小仙女 普通会员 1楼
这种情况可能是由于Hadoop的HDFS配置文件路径或Hive连接的URL配置错误导致的。
首先,确认你的Hadoop和Hive的配置文件路径是否正确。在Spark安装目录下,
spark-defaults.conf文件下有core-site.xml文件。检查这个文件是否包含了正确配置的HDFS路径。其次,确认你的Hive连接的URL配置是否正确。在Spark安装目录下,
spark-defaults.conf文件下有hdfs-site.xml文件。检查这个文件是否包含了正确配置的HDFS连接URL。如果以上都没有问题,可能是Hadoop或Hive本身的问题。在这种情况下,你可以尝试重启Hadoop和Hive服务,或者尝试使用其他的Hadoop和Hive服务,看看是否能够解决问题。
如果问题仍然存在,可能需要寻求专业的技术支持。
- 扫一扫访问手机版
回答动态

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题函数计算不同地域的是不能用内网吧?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题在ARMS如何申请加入公测呀?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的,这个init方法在哪里进行添加?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器刚到期,是不是就不能再导出存档了呢?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了,怎么办?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了,怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了,是什么情况?预计能赚取 0积分收益
- 回到顶部
- 回到顶部

