Update codestyle - uniform style for config values

maropu · Jun 26, 2015 · 63f53f4 · 63f53f4
1 parent 02031e4
commit 63f53f4
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala
@@ -59,8 +59,7 @@ private[spark] class MesosSchedulerBackend(
   private[mesos] val mesosExecutorCores = sc.conf.getDouble("spark.mesos.mesosExecutor.cores", 1)
 
   // Offer constraints
-  private[mesos] val constraintsStr = sc.conf.get("spark.mesos.constraints", "")
-  private[mesos] val offerConstraints = parseConstraintString(constraintsStr)
+  val slaveOfferConstraints = parseConstraintString(sc.conf.get("spark.mesos.constraints", ""))
 
   @volatile var appId: String = _
 
@@ -189,7 +188,7 @@ private[spark] class MesosSchedulerBackend(
    */
   override def resourceOffers(d: SchedulerDriver, offers: JList[Offer]) {
     inClassLoader() {
-      val qualifyingOffers = filterOffersByConstraints(offers, offerConstraints)
+      val qualifyingOffers = filterOffersByConstraints(offers, slaveOfferConstraints)
       // Fail-fast on offers we know will be rejected
       val (usableOffers, unUsableOffers) = qualifyingOffers.partition { o =>
         val mem = getResource(o.getResourcesList, "mem")