Modifying loop condition to find property match

prabeesh · May 24, 2015 · 4be3a8d · 4be3a8d
1 parent 0ee5642
commit 4be3a8d
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
@@ -265,15 +265,16 @@ object RpcTimeout {
 
     // Find the first set property or use the default value with the first property
     val itr = timeoutPropList.iterator
-    var foundProp =  (timeoutPropList.head,defaultValue)
-    while (itr.hasNext && (foundProp == (timeoutPropList.head,defaultValue))){
+    var foundProp =  None: Option[(String, String)]
+    while (itr.hasNext && foundProp.isEmpty){
       val propKey = itr.next()
       conf.getOption(propKey) match {
-        case Some(prop) => foundProp = (propKey,prop)
+        case Some(prop) => foundProp = Some(propKey,prop)
         case None =>
       }
     }
-    val timeout = { Utils.timeStringAsSeconds(foundProp._2) seconds }
-    new RpcTimeout(timeout, messagePrefix + foundProp._1)
+    val finalProp = foundProp.getOrElse(timeoutPropList.head, defaultValue)
+    val timeout = { Utils.timeStringAsSeconds(finalProp._2) seconds }
+    new RpcTimeout(timeout, messagePrefix + finalProp._1)
   }
 }