天天看點

pyspark報錯解決 “py4j.protocol.Py4JError: org.apache.spark.api.python.PythonUtils.isEncryptionEnabled“

報錯

py4j.protocol.Py4JError: org.apache.spark.api.python.PythonUtils.isEncryptionEnabled does not exist in the JVM

解決辦法,添加如下前兩行代碼,放在操作spark之前

#添加此代碼
import findspark
findspark.init()
#添加此代碼

from pyspark import SparkConf, SparkContext
           

作用就是初始化找到本機安裝的spark的環境