spark collect操作报错 py4j.protocol.Py4JJavaError
只要一执行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
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论