- 67
- 0
只要一执行action操作,比如take,count,就会报错,是Java文件安装不对嘛
Traceback (most recent call last):
File "/usr/software/spark-1.6.0/bin/simpleApp.py", line 7, in <module>
numAs=logData.filter(lambda x: 'a ' in x).collect()
File "/usr/software/spark-1.6.0/python/lib/pyspark.zip/pyspark/rdd.py", line 771, in collect
File "/usr/software/spark-1.6.0/python/lib/py4j-0.9-src.zip/py4j/java_gateway.py", line 813, in __call__
File "/usr/software/spark-1.6.0/python/lib/py4j-0.9-src.zip/py4j/protocol.py", line 308, in get_return_value
py4j.protocol.Py4JJavaError 3
打赏
收藏
点击回答
- 共 0 条
- 全部回答
-
城市野鹿 普通会员 1楼
这个错误表示你在使用Py4J库进行Spark作业时遇到了问题。Py4J是一个Python到Java的桥接程序,它可以帮助你将Python代码转换为Java代码。
问题可能有以下几个原因:
-
Java环境未安装:Py4J需要Java环境才能运行,如果没有安装,你可能需要先安装Java环境。
-
Py4J库版本过低:如果你的Py4J库版本过低,它可能无法处理某些Java方法,导致错误。
-
Java代码中的异常未处理:如果你的Java代码中包含异常,但是没有处理这些异常,Py4J可能无法处理它们,导致错误。
-
你的Spark作业依赖了某个Java库,而这个库在你的Java环境中不可用,这也会导致错误。
解决这个问题的方法有很多,首先你需要检查你的Java环境和Py4J库是否已经安装,以及它们的版本是否匹配。其次,你需要检查你的Java代码中是否有异常,如果有,你需要处理这些异常。最后,你需要检查你的Spark作业是否依赖了某个Java库,如果依赖了,你需要确保这个库在你的Java环境中可用。
-
更多回答
网站公告
- 扫一扫访问手机版
回答动态

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

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

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

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

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

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

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

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

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

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