在 pySpark 我得到 py4j.protocol.Py4JError: py4j.Py4JException: Method isBarrier([]) does not exist

Question

此异常正在上升lines.count()。

发生异常：py4j.protocol.Py4JError 调用 o26.isBarrier 时发生错误。跟踪：py4j.Py4JException：方法 isBarrier([]) 在 py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:318) 在 py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:326) 在 py4j.Gateway 不存在。 invoke(Gateway.java:274) at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
at py4j.commands.CallCommand.execute(CallCommand.java:79) at from pyspark import SparkContext from pyspark import SparkConf

代码：

    conf = SparkConf()

    conf.setAppName("First App")

    sc = SparkContext('local',conf=conf)
    print("-----------------------------------------------------------------------------")
    lines = sc.textFile("sample.csv")
    print("-----------------------------------------------------------------------------")
    lines.count()