Skip to content

Commit bf37e36

Browse files
committed
Minor changes
1 parent 01066fa commit bf37e36

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

bin/pyspark

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ export SPARK_HOME="$FWDIR"
2525

2626
SCALA_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

bin/spark-shell

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ esac
2828
# Enter posix mode for bash
2929
set -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

core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)