You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2016/03/13 11:18:13 UTC
spark git commit: [SPARK-13810][CORE] Add Port Configuration
Suggestions on Bind Exceptions
Repository: spark
Updated Branches:
refs/heads/master db88d0204 -> 515e4afbc
[SPARK-13810][CORE] Add Port Configuration Suggestions on Bind Exceptions
## What changes were proposed in this pull request?
Currently, when a java.net.BindException is thrown, it displays the following message:
java.net.BindException: Address already in use: Service '$serviceName' failed after 16 retries!
This change adds port configuration suggestions to the BindException, for example, for the UI, it now displays
java.net.BindException: Address already in use: Service 'SparkUI' failed after 16 retries! Consider explicitly setting the appropriate port for 'SparkUI' (for example spark.ui.port for SparkUI) to an available port or increasing spark.port.maxRetries.
## How was this patch tested?
Manual tests
Author: Bjorn Jonsson <bj...@gmail.com>
Closes #11644 from bjornjon/master.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/515e4afb
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/515e4afb
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/515e4afb
Branch: refs/heads/master
Commit: 515e4afbc7ec957609451ea75772d6ef1b914908
Parents: db88d02
Author: Bjorn Jonsson <bj...@gmail.com>
Authored: Sun Mar 13 10:18:24 2016 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Sun Mar 13 10:18:24 2016 +0000
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/util/Utils.scala | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/515e4afb/core/src/main/scala/org/apache/spark/util/Utils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
index 9688cca..b4c4951 100644
--- a/core/src/main/scala/org/apache/spark/util/Utils.scala
+++ b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -2014,8 +2014,10 @@ private[spark] object Utils extends Logging {
} catch {
case e: Exception if isBindCollision(e) =>
if (offset >= maxRetries) {
- val exceptionMessage =
- s"${e.getMessage}: Service$serviceString failed after $maxRetries retries!"
+ val exceptionMessage = s"${e.getMessage}: Service$serviceString failed after " +
+ s"$maxRetries retries! Consider explicitly setting the appropriate port for the " +
+ s"service$serviceString (for example spark.ui.port for SparkUI) to an available " +
+ "port or increasing spark.port.maxRetries."
val exception = new BindException(exceptionMessage)
// restore original stack trace
exception.setStackTrace(e.getStackTrace)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org