Я правильно настроил всю свою локальную переменную среды для 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)
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