【发布时间】:2019-09-24 23:33:09
【问题描述】:
我在使用 spark 时遇到此错误: Py4JError:调用 o25.isBarrier 时出错。痕迹: py4j.Py4JException: 方法 isBarrier([]) 不存在
版本检查和配置设置交叉检查
from pyspark import SparkContext
from pyspark.sql.session import SparkSession
sc = SparkContext()
spark = SparkSession(sc)
filepath = "D:\\DataScienceIntProgram\\spark\\a.us.csv"
us_stock = sc.textFile(filepath)
us_stock.take(10)
Py4JError:调用 o25.isBarrier 时出错。痕迹: py4j.Py4JException: 方法 isBarrier([]) 不存在
【问题讨论】: