diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-05-29 10:14:22 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-05-29 10:14:22 -0700 |
| commit | 6ed71390d9a9af4f48c6c1aa0e86feb8c8ad3272 (patch) | |
| tree | 8d484a9ee57e280cfb0ffe6a6c453976ee3f9c5e | |
| parent | 41d230ccb02ea3d731f56bf6ced3486cf13260f0 (diff) | |
| parent | 4fe1fbdd51f781157138ffd35da5834366379688 (diff) | |
| download | spark-6ed71390d9a9af4f48c6c1aa0e86feb8c8ad3272.tar.gz spark-6ed71390d9a9af4f48c6c1aa0e86feb8c8ad3272.tar.bz2 spark-6ed71390d9a9af4f48c6c1aa0e86feb8c8ad3272.zip | |
Merge pull request #626 from stephenh/remove-add-if-no-port
Remove unused addIfNoPort.
| -rw-r--r-- | core/src/main/scala/spark/Utils.scala | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/core/src/main/scala/spark/Utils.scala b/core/src/main/scala/spark/Utils.scala index c1495d5317..84626df553 100644 --- a/core/src/main/scala/spark/Utils.scala +++ b/core/src/main/scala/spark/Utils.scala @@ -403,17 +403,6 @@ private object Utils extends Logging { hostPortParseResults.get(hostPort) } - def addIfNoPort(hostPort: String, port: Int): String = { - if (port <= 0) throw new IllegalArgumentException("Invalid port specified " + port) - - // This is potentially broken - when dealing with ipv6 addresses for example, sigh ... but then hadoop does not support ipv6 right now. - // For now, we assume that if port exists, then it is valid - not check if it is an int > 0 - val indx: Int = hostPort.lastIndexOf(':') - if (-1 != indx) return hostPort - - hostPort + ":" + port - } - private[spark] val daemonThreadFactory: ThreadFactory = new ThreadFactoryBuilder().setDaemon(true).build() |