Не в состоянии запустить код Spark из -за некоторой проблемы на моем локальномJAVA

Программисты JAVA общаются здесь
Anonymous
Не в состоянии запустить код Spark из -за некоторой проблемы на моем локальном

Сообщение Anonymous »

Я сталкиваюсь с ошибкой ниже при выполнении данного кусочка кода Spark в моем локальном издании Pycharm Community Edition, и Spark Session не создается.
Я правильно настроил всю свою локальную переменную среды для JDK и Spark. Pyspark 3.5.6 Версии. Может ли кто -нибудь, пожалуйста, помочь мне решить эту проблему.
заранее спасибо !!! < /p>

Код: Выделить всё

from pyspark.sql import functions as f
from pyspark.sql import SparkSession
from pyspark.sql.functions import session_window
from pyspark.sql import Window
import os
import findspark

findspark.init("C:\\spark")
os.environ["JAVA_HOME"] = "C:\\Program Files\\Eclipse Adoptium\\jdk-11.0.22.7-hotspot"
os.environ["SPARK_HOME"] = "C:\\spark"
print("Pyspark Imported")
spark = SparkSession.builder.appName("CSVEXAMPLE").getOrCreate()

print("spark sessions started")
print("Spark Version:", spark.version)
the "Pyspark Imported" только печатается, затем приведена приведенная ошибка. Sparksessession.builder.appname ("csvexample"). Getorcreate () < /p>
file "c: \ users \ pythonproject.venv \ lib \ site-packages \ pyspark \ sql \ session.py", линия 559, в getorcreate < /p>
session = spars = spars = spar. Options = self._options)
file "c: \ users \ pythonproject.venv \ lib \ site-packages \ pyspark \ sql \ session.py", строка 635, в init
написано. /> ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~лки>

Подробнее здесь: https://stackoverflow.com/questions/797 ... n-my-local

Вернуться в «JAVA»