aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorjerryshao <saisai.shao@intel.com>2013-09-22 16:50:08 +0800
committerjerryshao <saisai.shao@intel.com>2013-09-22 16:50:08 +0800
commit77e9da1f34a0b9e556d7c0bbd4aeaa5c635b881d (patch)
tree71239dda6351242bb27c1ff7d82789fbb93918bf
parent85024acd2ed9d6b2a03422214865ebb48b2094b8 (diff)
downloadspark-77e9da1f34a0b9e556d7c0bbd4aeaa5c635b881d.tar.gz
spark-77e9da1f34a0b9e556d7c0bbd4aeaa5c635b881d.tar.bz2
spark-77e9da1f34a0b9e556d7c0bbd4aeaa5c635b881d.zip
Change Exception to NoSuchElementException and minor style fix
-rw-r--r--core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala13
1 files changed, 7 insertions, 6 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala
index 65b844a80e..114617c51a 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala
@@ -18,7 +18,7 @@
package org.apache.spark.scheduler.cluster
import java.io.{FileInputStream, InputStream}
-import java.util.Properties
+import java.util.{NoSuchElementException, Properties}
import org.apache.spark.Logging
@@ -65,15 +65,15 @@ private[spark] class FairSchedulableBuilder(val rootPool: Pool)
override def buildPools() {
var is: Option[InputStream] = None
try {
- is = Option{
- schedulerAllocFile.map{ f =>
+ is = Option {
+ schedulerAllocFile.map { f =>
new FileInputStream(f)
- }.getOrElse{
+ }.getOrElse {
getClass.getClassLoader.getResourceAsStream(DEFAULT_SCHEDULER_FILE)
}
}
- is.foreach{ i => buildFairSchedulerPool(i) }
+ is.foreach { i => buildFairSchedulerPool(i) }
} finally {
is.foreach(_.close())
}
@@ -106,7 +106,8 @@ private[spark] class FairSchedulableBuilder(val rootPool: Pool)
try {
schedulingMode = SchedulingMode.withName(xmlSchedulingMode)
} catch {
- case e: Exception => logWarning("Error xml schedulingMode, using default schedulingMode")
+ case e: NoSuchElementException =>
+ logWarning("Error xml schedulingMode, using default schedulingMode")
}
}