join sparkcmd

lukemartinlogan · lukemartinlogan · commit 17f6054ba0a9 · 2024-03-30T18:11:58.000-05:00
diff --git a/jarvis_util/shell/spark_exec.py b/jarvis_util/shell/spark_exec.py
@@ -26,5 +26,5 @@ def __init__(self, cmd, master_host, master_port,
             f'--conf spark.local.dir={scratch}',
             cmd
         ]
-        sparkcmd = ' '.join(cmd)
+        sparkcmd = ' '.join(sparkcmd)
         super().__init__(sparkcmd, exec_info)

Original file line number	Diff line number	Diff line change
`@@ -26,5 +26,5 @@ def __init__(self, cmd, master_host, master_port,`
`26`	`26`	`f'--conf spark.local.dir={scratch}',`
`27`	`27`	`cmd`
`28`	`28`	`]`
`29`		`- sparkcmd = ' '.join(cmd)`
	`29`	`+ sparkcmd = ' '.join(sparkcmd)`
`30`	`30`	`super().__init__(sparkcmd, exec_info)`