I
Size: a a a
I
GP
GP
I
MP
Е
A
ЕГ
Е
spark = SparkSession.builder.getOrCreate()
File "/app/spark-3.0.3-bin-hadoop2.7/python/pyspark/sql/session.py", line 186, in getOrCreate
sc = SparkContext.getOrCreate(sparkConf)
File "/app/spark-3.0.3-bin-hadoop2.7/python/pyspark/context.py", line 378, in getOrCreate
SparkContext(conf=conf or SparkConf())
File "/app/spark-3.0.3-bin-hadoop2.7/python/pyspark/context.py", line 133, in __init__
SparkContext._ensure_initialized(self, gateway=gateway, conf=conf)
File "/app/spark-3.0.3-bin-hadoop2.7/python/pyspark/context.py", line 327, in _ensure_initialized
SparkContext._gateway = gateway or launch_gateway(conf)
File "/app/spark-3.0.3-bin-hadoop2.7/python/pyspark/java_gateway.py", line 95, in launch_gateway
proc = Popen(command, **popen_kwargs)
File "/opt/conda/lib/python3.9/subprocess.py", line 951, in __init__
self._execute_child(args, executable, preexec_fn, close_fds,
File "/opt/conda/lib/python3.9/subprocess.py", line 1821, in _execute_child
raise child_exception_type(errno_num, err_msg, err_filename)
FileNotFoundError: [Errno 2] No such file or directory: 'spark-3.0.3-bin-hadoop2.7/./bin/spark-submit'
script = "./bin/spark-submit"
command = [os.path.join(SPARK_HOME, script)]
ЕГ
Е
ЕГ
ЕГ
Е
Е
ЕГ
Е
Е
ЕГ
ЕГ