只要一执行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