fix bug in isBindCollision

harishreedharan · Oct 1, 2014 · 3a6c849 · 3a6c849
1 parent c5414b6
commit 3a6c849
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -23,6 +23,8 @@ import java.nio.ByteBuffer
 import java.util.{Properties, Locale, Random, UUID}
 import java.util.concurrent.{ThreadFactory, ConcurrentHashMap, Executors, ThreadPoolExecutor}
 
+import org.eclipse.jetty.util.MultiException
+
 import scala.collection.JavaConversions._
 import scala.collection.Map
 import scala.collection.mutable.ArrayBuffer
@@ -1470,6 +1472,7 @@ private[spark] object Utils extends Logging {
           return true
         }
         isBindCollision(e.getCause)
+      case e: MultiException => e.getThrowables.map(ex => isBindCollision(ex)).reduceLeft(_ || _)
       case e: Exception => isBindCollision(e.getCause)
       case _ => false
     }