Special case non-"Address already in use" exceptions

apache · Aug 5, 2014 · 470f38c · 470f38c
1 parent 1d7e408
commit 470f38c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -1357,7 +1357,10 @@ private[spark] object Utils extends Logging {
         return (service, port)
       } catch {
         case e: BindException =>
-          if (!e.getMessage.contains("Address already in use") || offset >= maxRetries) {
+          if (!e.getMessage.contains("Address already in use")) {
+            throw e
+          }
+          if (offset >= maxRetries) {
             val exceptionMessage =
               s"${e.getMessage}: Service$serviceString failed after $maxRetries retries!"
             val exception = new BindException(exceptionMessage)