Untitled

\new_try\S8\s8-lessons> & C:/Users/vkhdk/AppData/Local/Programs/Python/Python311/python.exe "d:/Vova_folder/Study/yandex_DE/new_try/S8/s8-lessons/Тема 3. Настройка потока данных/4. Изучение данных в Kafka со Spark/Задание 1/realization.py"
Java not found and JAVA_HOME environment variable is not set.
Install Java and set JAVA_HOME to point to the Java installation directory.
Traceback (most recent call last):
  File "d:\Vova_folder\Study\yandex_DE\new_try\S8\s8-lessons\Тема 3. Настройка потока данных\4. Изучение данных в Kafka со Spark\Задание 1\realization.py", line 18, in <module>
    .getOrCreate()
     ^^^^^^^^^^^^^
  File "C:\Users\vkhdk\AppData\Local\Programs\Python\Python311\Lib\site-packages\pyspark\sql\session.py", line 497, in getOrCreate
    sc = SparkContext.getOrCreate(sparkConf)
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\vkhdk\AppData\Local\Programs\Python\Python311\Lib\site-packages\pyspark\context.py", line 515, in getOrCreate
    SparkContext(conf=conf or SparkConf())
  File "C:\Users\vkhdk\AppData\Local\Programs\Python\Python311\Lib\site-packages\pyspark\context.py", line 201, in __init__
    SparkContext._ensure_initialized(self, gateway=gateway, conf=conf)
  File "C:\Users\vkhdk\AppData\Local\Programs\Python\Python311\Lib\site-packages\pyspark\context.py", line 436, in _ensure_initialized
    SparkContext._gateway = gateway or launch_gateway(conf)
                                       ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\vkhdk\AppData\Local\Programs\Python\Python311\Lib\site-packages\pyspark\java_gateway.py", line 107, in launch_gateway
    raise PySparkRuntimeError(
pyspark.errors.exceptions.base.PySparkRuntimeError: [JAVA_GATEWAY_EXITED] Java gateway process exited before sending its port number.
PS D:\Vova_folder\Study\yandex_DE\new_try\S8\s8-lessons>