bug fix: --spark_env for the pyspark plugin, if defined, should expec…

…t at least one argument
sailthru · Dec 20, 2014 · f065c4c · f065c4c
1 parent 83a85c9
commit f065c4c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stolos/plugins/pyspark_plugin.py b/stolos/plugins/pyspark_plugin.py
@@ -131,7 +131,7 @@ def _validate_sample_size(str_i):
               " the task's default settings. ie:"
               " spark.master=local[4] spark.ui.port=4046")),
     at.add_argument(
-        '--spark_env', nargs='*',
+        '--spark_env', nargs='+',
         type=lambda x: x.split('='), default=[],
         help=("A list of key=value pairs to add to the spark executor's"
               " environment.  ie:"