diff options
| author | Henry Saputra <hsaputra@apache.org> | 2014-01-12 19:15:09 -0800 |
|---|---|---|
| committer | Henry Saputra <hsaputra@apache.org> | 2014-01-12 19:15:09 -0800 |
| commit | 5a8abfb70efd89ec4120c7f78596d8b32a9f4f3d (patch) | |
| tree | 216544d119cda6e775e97b3c6eb47be3e45e89d7 /yarn | |
| parent | f1c5eca494f798fc22c46d245435381a89098fe4 (diff) | |
| download | spark-5a8abfb70efd89ec4120c7f78596d8b32a9f4f3d.tar.gz spark-5a8abfb70efd89ec4120c7f78596d8b32a9f4f3d.tar.bz2 spark-5a8abfb70efd89ec4120c7f78596d8b32a9f4f3d.zip | |
Address code review concerns and comments.
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 6 | ||||
| -rw-r--r-- | yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala index e1fe09e3e2..e56bc02897 100644 --- a/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala +++ b/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala @@ -191,10 +191,10 @@ class Client(args: ClientArguments, conf: Configuration, sparkConf: SparkConf) } //check for ports if (srcUri.getPort() != dstUri.getPort()) { - false - } else { - true + return false } + + true } /** Copy the file into HDFS if needed. */ diff --git a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala index c084485734..51d9adb9d4 100644 --- a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala +++ b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala @@ -206,10 +206,10 @@ class Client(args: ClientArguments, conf: Configuration, sparkConf: SparkConf) } //check for ports if (srcUri.getPort() != dstUri.getPort()) { - false - } else { - true + return false } + + true } /** Copy the file into HDFS if needed. */ |