diff options
author | jerryshao <saisai.shao@intel.com> | 2013-09-13 09:15:31 +0800 |
---|---|---|
committer | jerryshao <saisai.shao@intel.com> | 2013-09-22 14:20:55 +0800 |
commit | 85024acd2ed9d6b2a03422214865ebb48b2094b8 (patch) | |
tree | 9eca65242f9361e0c9c95447fd254ba7a368a24b /core | |
parent | 5850f599dd93d2871e4e9777531cbbcae80a2475 (diff) | |
download | spark-85024acd2ed9d6b2a03422214865ebb48b2094b8.tar.gz spark-85024acd2ed9d6b2a03422214865ebb48b2094b8.tar.bz2 spark-85024acd2ed9d6b2a03422214865ebb48b2094b8.zip |
Remove infix style and others
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/cluster/SchedulableBuilder.scala | 18 |
1 files changed, 8 insertions, 10 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 f25924befa..65b844a80e 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 @@ -17,14 +17,12 @@ package org.apache.spark.scheduler.cluster -import java.io.{File, FileInputStream, FileOutputStream, FileNotFoundException, InputStream} +import java.io.{FileInputStream, InputStream} import java.util.Properties -import scala.xml.XML - import org.apache.spark.Logging -import org.apache.spark.scheduler.cluster.SchedulingMode.SchedulingMode +import scala.xml.XML /** * An interface to build Schedulable tree @@ -67,17 +65,17 @@ 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) + is.foreach(_.close()) } // finally create "default" pool @@ -108,7 +106,7 @@ private[spark] class FairSchedulableBuilder(val rootPool: Pool) try { schedulingMode = SchedulingMode.withName(xmlSchedulingMode) } catch { - case e: Exception => logInfo("Error xml schedulingMode, using default schedulingMode") + case e: Exception => logWarning("Error xml schedulingMode, using default schedulingMode") } } |