We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f74064d commit 0ee5642Copy full SHA for 0ee5642
core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
@@ -266,7 +266,7 @@ object RpcTimeout {
266
// Find the first set property or use the default value with the first property
267
val itr = timeoutPropList.iterator
268
var foundProp = (timeoutPropList.head,defaultValue)
269
- while (itr.hasNext){
+ while (itr.hasNext && (foundProp == (timeoutPropList.head,defaultValue))){
270
val propKey = itr.next()
271
conf.getOption(propKey) match {
272
case Some(prop) => foundProp = (propKey,prop)
0 commit comments