diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-05-28 16:26:32 -0500 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-05-28 16:26:32 -0500 |
| commit | 4fe1fbdd51f781157138ffd35da5834366379688 (patch) | |
| tree | df9eba383e7c6896bc20a8e1807f6b1eb728fdd4 | |
| parent | 3db1e17baa11fa37b0c7f04d7213a30df66d1611 (diff) | |
| download | spark-4fe1fbdd51f781157138ffd35da5834366379688.tar.gz spark-4fe1fbdd51f781157138ffd35da5834366379688.tar.bz2 spark-4fe1fbdd51f781157138ffd35da5834366379688.zip | |
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() |