diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-10-01 16:03:00 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-10-01 16:03:00 -0700 |
| commit | 4e79970d32f9b917590dba8319bdc677e3bdd63a (patch) | |
| tree | 01165d25bca33ae0b14f651e28d6aec415c6a5de /core | |
| parent | a31f4ff22f98c01f0d9b7d1240080ff2689c1270 (diff) | |
| download | spark-4e79970d32f9b917590dba8319bdc677e3bdd63a.tar.gz spark-4e79970d32f9b917590dba8319bdc677e3bdd63a.tar.bz2 spark-4e79970d32f9b917590dba8319bdc677e3bdd63a.zip | |
Revert "[SPARK-3755][Core] Do not bind port 1 - 1024 to server in spark"
This reverts commit 6390aae4eacbabfb1c53fb828b824f6a6518beff.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/Utils.scala | 2 |
1 files changed, 1 insertions, 1 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 index e5b83c069d..b3025c6ec3 100644 --- a/core/src/main/scala/org/apache/spark/util/Utils.scala +++ b/core/src/main/scala/org/apache/spark/util/Utils.scala @@ -1439,7 +1439,7 @@ private[spark] object Utils extends Logging { val serviceString = if (serviceName.isEmpty) "" else s" '$serviceName'" for (offset <- 0 to maxRetries) { // Do not increment port if startPort is 0, which is treated as a special port - val tryPort = if (startPort == 0) startPort else (startPort + offset) % (65536 - 1024) + 1024 + val tryPort = if (startPort == 0) startPort else (startPort + offset) % 65536 try { val (service, port) = startService(tryPort) logInfo(s"Successfully started service$serviceString on port $port.") |