原因:

spark 读取本地文件

spark默认去hdfs寻找,然而我的放在本地,应该改为:
默认是从hdfs读取文件,也可以指定sc.textFile("路径").在路径前面加上hdfs://表示从hdfs文件系统上读
本地文件读取 sc.textFile("路径").在路径前面加上file:// 表示从本地文件系统读,如file:///home/user/spark/README.md

spark 报错 py4j.protocol.Py4JJavaError错误-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客