This commit is contained in:
Timothee Guerin 2017-07-12 15:12:25 -07:00
Родитель f7b22be1dc
Коммит b72a9bc935
1 изменённых файлов: 3 добавлений и 1 удалений

Просмотреть файл

@ -112,8 +112,10 @@ def start_jupyter():
my_env["PYSPARK_DRIVER_PYTHON"] = "/anaconda/envs/py35/bin/jupyter"
my_env["PYSPARK_DRIVER_PYTHON_OPTS"] = "notebook --no-browser --port='{0}'".format(jupyter_port)
pyspark_wd = os.path.join(os.getcwd(), "pyspark")
os.mkdir(pyspark_wd)
print("Starting pyspark")
process = Popen(["pyspark"], env=my_env)
process = Popen(["pyspark"], env=my_env, cwd=pyspark_wd)
print("Started pyspark with pid {0}".format(process.pid))