Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Minor changes
  • Loading branch information
andrewor14 committed May 17, 2014
commit bf37e36d15d85f10f43152cb35b52358132e6887
2 changes: 1 addition & 1 deletion bin/pyspark
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ export SPARK_HOME="$FWDIR"

SCALA_VERSION=2.10

if [[ "$@" = *--help ]] || [[ "$@" = *--h ]]; then
if [[ "$@" = *--help ]] || [[ "$@" = *-h ]]; then
echo "Usage: ./bin/pyspark [options]"
./bin/spark-submit --help 2>&1 | grep -v Usage 1>&2
exit 0
Expand Down
2 changes: 1 addition & 1 deletion bin/spark-shell
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ esac
# Enter posix mode for bash
set -o posix

if [[ "$@" = *--help ]] || [[ "$@" = *--h ]]; then
if [[ "$@" = *--help ]] || [[ "$@" = *-h ]]; then
echo "Usage: ./bin/spark-shell [options]"
./bin/spark-submit --help 2>&1 | grep -v Usage 1>&2
exit 0
Expand Down
9 changes: 4 additions & 5 deletions core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
Original file line number Diff line number Diff line change
Expand Up @@ -334,11 +334,10 @@ object SparkSubmit {
* no files, into a single comma-separated string.
*/
private[spark] def mergeFileLists(lists: String*): String = {
lists
.filter(_ != null)
.filter(_ != "")
.flatMap(_.split(","))
.mkString(",")
val merged = lists.filter(_ != null)
.flatMap(_.split(","))
.mkString(",")
if (merged == "") null else merged
}
}

Expand Down