File tree Expand file tree Collapse file tree 1 file changed +9
-14
lines changed Expand file tree Collapse file tree 1 file changed +9
-14
lines changed Original file line number Diff line number Diff line change @@ -65,35 +65,30 @@ while (($#)); do
6565 case $1 in
6666 -d | --define | --database | -f | -h | --hiveconf | --hivevar | -i | -p)
6767 ensure_arg_number $# 2
68- CLI_ARGS+=($1 ); shift
69- CLI_ARGS+=($1 ); shift
68+ CLI_ARGS+=(" $1 " ); shift
69+ CLI_ARGS+=(" $1 " ); shift
7070 ;;
7171
7272 -e)
7373 ensure_arg_number $# 2
74- CLI_ARGS+=($1 ); shift
75- CLI_ARGS+=(\ "$1 \ " ); shift
74+ CLI_ARGS+=(" $1 " ); shift
75+ CLI_ARGS+=(" $1 " ); shift
7676 ;;
7777
7878 -s | --silent)
79- CLI_ARGS+=($1 ); shift
79+ CLI_ARGS+=(" $1 " ); shift
8080 ;;
8181
8282 -v | --verbose)
8383 # Both SparkSubmit and SparkSQLCLIDriver recognizes -v | --verbose
84- CLI_ARGS+=($1 )
85- SUBMISSION_ARGS+=($1 ); shift
86- ;;
87-
88- --driver-java-options)
89- shift ;
90- export SPARK_SUBMIT_OPTS=$1 ; shift
84+ CLI_ARGS+=(" $1 " )
85+ SUBMISSION_ARGS+=(" $1 " ); shift
9186 ;;
9287
9388 * )
94- SUBMISSION_ARGS+=($1 ); shift
89+ SUBMISSION_ARGS+=(" $1 " ); shift
9590 ;;
9691 esac
9792done
9893
99- eval exec " $FWDIR " /bin/spark-submit --class $CLASS ${SUBMISSION_ARGS[*]} spark-internal ${CLI_ARGS[*]}
94+ exec " $FWDIR " /bin/spark-submit --class $CLASS " ${SUBMISSION_ARGS[@]} " spark-internal " ${CLI_ARGS[@]} "
You can’t perform that action at this time.
0 commit comments