【问题标题】:Py4JError: An error occurred while calling o25.isBarrier. Trace: py4j.Py4JException: Method isBarrier([]) does not existPy4JError:调用 o25.isBarrier 时出错。跟踪:py4j.Py4JException:方法 isBarrier([]) 不存在
【发布时间】: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([]) 不存在

【问题讨论】:

    标签: pyspark py4j


    【解决方案1】:

    此问题与“sc.version”、“sc._jsc.version()”和“conda list pyspark”的版本不匹配有关。

    【讨论】:

    • 您找到解决方案了吗?
    • 是的,解决方案是 - 这个问题与“sc.version”、“sc._jsc.version()”和“conda list pyspark”的版本不匹配有关。
    猜你喜欢
    • 2019-07-26
    • 1970-01-01
    • 2019-05-21
    • 1970-01-01
    • 2023-02-01
    • 2017-04-12
    • 2015-11-11
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多