File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
core/src/main/scala/org/apache/spark/rpc Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -265,15 +265,16 @@ object RpcTimeout {
265
265
266
266
// Find the first set property or use the default value with the first property
267
267
val itr = timeoutPropList.iterator
268
- var foundProp = (timeoutPropList.head,defaultValue)
269
- while (itr.hasNext && ( foundProp == (timeoutPropList.head,defaultValue)) ){
268
+ var foundProp = None : Option [( String , String )]
269
+ while (itr.hasNext && foundProp.isEmpty ){
270
270
val propKey = itr.next()
271
271
conf.getOption(propKey) match {
272
- case Some (prop) => foundProp = (propKey,prop)
272
+ case Some (prop) => foundProp = Some (propKey,prop)
273
273
case None =>
274
274
}
275
275
}
276
- val timeout = { Utils .timeStringAsSeconds(foundProp._2) seconds }
277
- new RpcTimeout (timeout, messagePrefix + foundProp._1)
276
+ val finalProp = foundProp.getOrElse(timeoutPropList.head, defaultValue)
277
+ val timeout = { Utils .timeStringAsSeconds(finalProp._2) seconds }
278
+ new RpcTimeout (timeout, messagePrefix + finalProp._1)
278
279
}
279
280
}
You can’t perform that action at this time.
0 commit comments