Skip to content

Commit 3a6c849

Browse files
committed
fix bug in isBindCollision
1 parent c5414b6 commit 3a6c849

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/src/main/scala/org/apache/spark/util/Utils.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@ import java.nio.ByteBuffer
2323
import java.util.{Properties, Locale, Random, UUID}
2424
import java.util.concurrent.{ThreadFactory, ConcurrentHashMap, Executors, ThreadPoolExecutor}
2525

26+
import org.eclipse.jetty.util.MultiException
27+
2628
import scala.collection.JavaConversions._
2729
import scala.collection.Map
2830
import scala.collection.mutable.ArrayBuffer
@@ -1470,6 +1472,7 @@ private[spark] object Utils extends Logging {
14701472
return true
14711473
}
14721474
isBindCollision(e.getCause)
1475+
case e: MultiException => e.getThrowables.map(ex => isBindCollision(ex)).reduceLeft(_ || _)
14731476
case e: Exception => isBindCollision(e.getCause)
14741477
case _ => false
14751478
}

0 commit comments

Comments
 (0)