File tree Expand file tree Collapse file tree 2 files changed +23
-17
lines changed Expand file tree Collapse file tree 2 files changed +23
-17
lines changed Original file line number Diff line number Diff line change @@ -58,31 +58,37 @@ if [[ "$@" = --help ]] || [[ "$@" = -h ]]; then
58
58
exit 0
59
59
fi
60
60
61
- CLI_ARGS=" "
62
- SUBMISSION_ARGS=" "
61
+ CLI_ARGS=()
62
+ SUBMISSION_ARGS=()
63
63
64
64
while (( $# )) ; do
65
- case $1 in
66
- -d | --define | --database | -e | - f | -h | --hiveconf | --hivevar | -i | -p)
65
+ case $1 in
66
+ -d | --define | --database | -f | -h | --hiveconf | --hivevar | -i | -p)
67
67
ensure_arg_number $# 2
68
- CLI_ARGS+=" $1 " ; shift
69
- CLI_ARGS+=" $1 " ; shift
68
+ CLI_ARGS+=($1 ); shift
69
+ CLI_ARGS+=($1 ); shift
70
+ ;;
71
+
72
+ -e)
73
+ ensure_arg_number $# 2
74
+ CLI_ARGS+=($1 ); shift
75
+ CLI_ARGS+=(\" $1 \" ); shift
70
76
;;
71
77
72
78
-s | --silent)
73
- CLI_ARGS+=" $1 " ; shift
79
+ CLI_ARGS+=( $1 ) ; shift
74
80
;;
75
81
76
82
-v | --verbose)
77
83
# Both SparkSubmit and SparkSQLCLIDriver recognizes -v | --verbose
78
- CLI_ARGS+=" $1 "
79
- SUBMISSION_ARGS+=" $1 " ; shift
84
+ CLI_ARGS+=( $1 )
85
+ SUBMISSION_ARGS+=( $1 ) ; shift
80
86
;;
81
87
82
88
* )
83
- SUBMISSION_ARGS+=" $1 " ; shift
89
+ SUBMISSION_ARGS+=( $1 ) ; shift
84
90
;;
85
91
esac
86
92
done
87
93
88
- exec " $FWDIR " /bin/spark-submit --class $CLASS $SUBMISSION_ARGS spark-internal $CLI_ARGS
94
+ eval exec " $FWDIR " /bin/spark-submit --class $CLASS ${ SUBMISSION_ARGS[*]} spark-internal ${ CLI_ARGS[*]}
Original file line number Diff line number Diff line change @@ -58,21 +58,21 @@ if [[ "$@" = --help ]] || [[ "$@" = -h ]]; then
58
58
exit 0
59
59
fi
60
60
61
- THRIFT_SERVER_ARGS=" "
62
- SUBMISSION_ARGS=" "
61
+ THRIFT_SERVER_ARGS=()
62
+ SUBMISSION_ARGS=()
63
63
64
64
while (( $# )) ; do
65
65
case $1 in
66
66
--hiveconf)
67
67
ensure_arg_number $# 2
68
- THRIFT_SERVER_ARGS+=" $1 " ; shift
69
- THRIFT_SERVER_ARGS+=" $1 " ; shift
68
+ THRIFT_SERVER_ARGS+=( $1 ) ; shift
69
+ THRIFT_SERVER_ARGS+=( $1 ) ; shift
70
70
;;
71
71
72
72
* )
73
- SUBMISSION_ARGS+=" $1 " ; shift
73
+ SUBMISSION_ARGS+=( $1 ) ; shift
74
74
;;
75
75
esac
76
76
done
77
77
78
- exec " $FWDIR " /bin/spark-submit --class $CLASS $SUBMISSION_ARGS spark-internal $THRIFT_SERVER_ARGS
78
+ eval exec " $FWDIR " /bin/spark-submit --class $CLASS ${ SUBMISSION_ARGS[*]} spark-internal ${ THRIFT_SERVER_ARGS[*]}
You can’t perform that action at this time.
0 commit comments