This commit is contained in:
Timothee Guerin 2017-07-13 15:23:49 -07:00
Родитель 9a4eccda1f
Коммит 6a2a54c2f1
1 изменённых файлов: 1 добавлений и 1 удалений

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

@ -144,6 +144,6 @@ def start_spark_worker():
my_env = os.environ.copy()
my_env["SPARK_MASTER_IP"] = master_node.ip_address
cmd = [exe, "spark://{0}:7077".format(master_node.ip_address), "--webui-port", str(config.WORKER_UI_PORT`)]
cmd = [exe, "spark://{0}:7077".format(master_node.ip_address), "--webui-port", str(config.WORKER_UI_PORT)]
print("Connecting to master with '{0}'".format(" ".join(cmd)))
call(cmd)