qualify utils class for livy

sparklyr · Oct 19, 2018 · 115f29f · 115f29f
1 parent ebae3bb
commit 115f29f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/java/spark-1.5.2/backend.scala b/java/spark-1.5.2/backend.scala
@@ -168,7 +168,7 @@ class Backend() {
         logger = new Logger("Backend", sessionId)
         if (isWorker) logger = new Logger("Worker", sessionId)
 
-        val newPort = Utils.nextPort(port, inetAddress)
+        val newPort = sparklyr.Utils.nextPort(port, inetAddress)
         logger.log("found port " + newPort + " is available")
 
         gatewayServerSocket = new ServerSocket(newPort, 1, inetAddress)

diff --git a/java/spark-1.5.2/channel.scala b/java/spark-1.5.2/channel.scala
@@ -36,13 +36,13 @@ class BackendChannel(logger: Logger, terminate: () => Unit, serializer: Serializ
       val anyIpAddress = Array[Byte](0, 0, 0, 0)
       val anyInetAddress = InetAddress.getByAddress(anyIpAddress)
 
-      val channelPort = if (deterministicPort) Utils.nextPort(port, anyInetAddress) else 0
+      val channelPort = if (deterministicPort) sparklyr.Utils.nextPort(port, anyInetAddress) else 0
       logger.log("is using port " + channelPort + " for backend channel")
 
       inetAddress = new InetSocketAddress(anyInetAddress, channelPort)
     }
     else {
-      val channelPort = if (deterministicPort) Utils.nextPort(port, InetAddress.getLoopbackAddress()) else 0
+      val channelPort = if (deterministicPort) sparklyr.Utils.nextPort(port, InetAddress.getLoopbackAddress()) else 0
       logger.log("is using port " + channelPort + " for backend channel")
 
       inetAddress = new InetSocketAddress(InetAddress.getLoopbackAddress(), channelPort)