今天小編用Python編寫Spark程序報了如下異常:
py4j.protocol.Py4JJavaError: An error occurred while calling z:org.apache.spark.api.python.PythonRDD.collectAndServe.
: java.lang.IllegalArgumentException: Unsupported class file major version 55
從網上找到的解決方案是JDK版本問題,於是乎小編將Java11降低為了Java8,重啟編譯器運行,還是報同樣錯。不過還好,我們可以使用代碼手動指定要使用的JDK。
在代碼開頭加上如下代碼即可:
import os java8_location = 'C:\Program Files\Java\jdk1.8.0_241' # 設置你自己的路徑 os.environ['JAVA_HOME'] = java8_location
重新運行就可以了。