File tree Expand file tree Collapse file tree 3 files changed +6
-7
lines changed
core/src/main/scala/org/apache/spark/deploy Expand file tree Collapse file tree 3 files changed +6
-7
lines changed Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ export SPARK_HOME="$FWDIR"
2525
2626SCALA_VERSION=2.10
2727
28- if [[ " $@ " = * --help ]] || [[ " $@ " = * -- h ]]; then
28+ if [[ " $@ " = * --help ]] || [[ " $@ " = * -h ]]; then
2929 echo " Usage: ./bin/pyspark [options]"
3030 ./bin/spark-submit --help 2>&1 | grep -v Usage 1>&2
3131 exit 0
Original file line number Diff line number Diff line change 2828# Enter posix mode for bash
2929set -o posix
3030
31- if [[ " $@ " = * --help ]] || [[ " $@ " = * -- h ]]; then
31+ if [[ " $@ " = * --help ]] || [[ " $@ " = * -h ]]; then
3232 echo " Usage: ./bin/spark-shell [options]"
3333 ./bin/spark-submit --help 2>&1 | grep -v Usage 1>&2
3434 exit 0
Original file line number Diff line number Diff line change @@ -334,11 +334,10 @@ object SparkSubmit {
334334 * no files, into a single comma-separated string.
335335 */
336336 private [spark] def mergeFileLists (lists : String * ): String = {
337- lists
338- .filter(_ != null )
339- .filter(_ != " " )
340- .flatMap(_.split(" ," ))
341- .mkString(" ," )
337+ val merged = lists.filter(_ != null )
338+ .flatMap(_.split(" ," ))
339+ .mkString(" ," )
340+ if (merged == " " ) null else merged
342341 }
343342}
344343
You can’t perform that action at this time.
0 commit comments