最近上线代码需要用到pyspark,一直报错:py4j.protocol.Py4JJavaError: An error occurred while calling z:org.apache.spark.api.python.PythonRDD.collectAndServe.
本来以为是自己的语法问题,改了半天无果。后来发现可能是jdk的版本与spark版本不兼容的问题,换了一个版本的jdk就解决了
最近上线代码需要用到pyspark,一直报错:py4j.protocol.Py4JJavaError: An error occurred while calling z:org.apache.spark.api.python.PythonRDD.collectAndServe.
本来以为是自己的语法问题,改了半天无果。后来发现可能是jdk的版本与spark版本不兼容的问题,换了一个版本的jdk就解决了