File tree Expand file tree Collapse file tree 1 file changed +9
-3
lines changed
core/src/main/scala/org/apache/spark/rpc Expand file tree Collapse file tree 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -264,9 +264,15 @@ object RpcTimeout {
264
264
require(timeoutPropList.nonEmpty)
265
265
266
266
// Find the first set property or use the default value with the first property
267
- val foundProp = timeoutPropList.view.map(x => (x, conf.getOption(x))).filter(_._2.isDefined).
268
- map(y => (y._1, y._2.get)).headOption.getOrElse(timeoutPropList.head, defaultValue)
269
-
267
+ val itr = timeoutPropList.iterator
268
+ var foundProp = (timeoutPropList.head,defaultValue)
269
+ while (itr.hasNext){
270
+ val propKey = itr.next()
271
+ conf.getOption(propKey) match {
272
+ case Some (prop) => foundProp = (propKey,prop)
273
+ case None =>
274
+ }
275
+ }
270
276
val timeout = { Utils .timeStringAsSeconds(foundProp._2) seconds }
271
277
new RpcTimeout (timeout, messagePrefix + foundProp._1)
272
278
}
You can’t perform that action at this time.
0 commit comments