File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -206,6 +206,7 @@ def run(
206
206
user code file (default: None).
207
207
"""
208
208
self ._current_job_name = self ._generate_current_job_name (job_name = job_name )
209
+ self .command = []
209
210
210
211
super ().run (
211
212
submit_app ,
@@ -737,6 +738,7 @@ def run(
737
738
user code file (default: None).
738
739
"""
739
740
self ._current_job_name = self ._generate_current_job_name (job_name = job_name )
741
+ self .command = [_SparkProcessorBase ._default_command ]
740
742
741
743
if not submit_app :
742
744
raise ValueError ("submit_app is required" )
@@ -917,6 +919,7 @@ def run(
917
919
user code file (default: None).
918
920
"""
919
921
self ._current_job_name = self ._generate_current_job_name (job_name = job_name )
922
+ self .command = [_SparkProcessorBase ._default_command ]
920
923
921
924
if not submit_app :
922
925
raise ValueError ("submit_app is required" )
You can’t perform that action at this time.
0 commit comments