diff --git a/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala b/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala index 42e216906ae33..22c92468679bc 100644 --- a/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala +++ b/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala @@ -17,16 +17,16 @@ package org.apache.spark.util +import scala.collection.JavaConversions.mapAsJavaMap + import akka.actor.{ActorRef, ActorSystem, ExtendedActorSystem} import akka.pattern.ask import com.typesafe.config.ConfigFactory import org.apache.log4j.{Level, Logger} -import org.apache.spark.rpc.RpcTimeout import org.apache.spark.{Logging, SecurityManager, SparkConf, SparkEnv, SparkException} - -import scala.collection.JavaConversions.mapAsJavaMap +import org.apache.spark.rpc.RpcTimeout /** * Various utility classes for working with Akka. diff --git a/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala index a806259e6499c..35d3f156ba285 100644 --- a/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala +++ b/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala @@ -564,7 +564,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll { val rt2 = RpcTimeout(conf, Seq("spark.ask.invalid.timeout", testProp, secondaryProp), "1s") assert( testDurationSeconds === rt2.duration.toSeconds ) - // Construct RpcTimeout with default value, + // Construct RpcTimeout with default value, val defaultProp = "spark.ask.default.timeout" val defaultDurationSeconds = 1 val rt3 = RpcTimeout(conf, Seq(defaultProp), defaultDurationSeconds.toString + "s") diff --git a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala index faab3c29884ee..6f673e518f6d4 100644 --- a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala +++ b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala @@ -22,13 +22,13 @@ import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.duration._ import scala.language.postfixOps -import akka.actor.{ActorSystem, Actor, Props} +import akka.actor.{Actor, ActorSystem, Props} import akka.pattern.ask -import com.typesafe.config.{ConfigValueFactory, ConfigFactory} +import com.typesafe.config.{ConfigFactory, ConfigValueFactory} -import org.apache.spark.rpc._ import org.apache.spark.{SecurityManager, SparkConf} +import org.apache.spark.rpc._ class AkkaRpcEnvSuite extends RpcEnvSuite {