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
阅读 5.6k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题