Skip to content

Commit 1b9beab

Browse files
committed
[SPARK-6980] Cleaned up import ordering
1 parent 08f5afc commit 1b9beab

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

core/src/main/scala/org/apache/spark/util/AkkaUtils.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,16 +17,16 @@
1717

1818
package org.apache.spark.util
1919

20+
import scala.collection.JavaConversions.mapAsJavaMap
21+
2022
import akka.actor.{ActorRef, ActorSystem, ExtendedActorSystem}
2123
import akka.pattern.ask
2224

2325
import com.typesafe.config.ConfigFactory
2426

2527
import org.apache.log4j.{Level, Logger}
26-
import org.apache.spark.rpc.RpcTimeout
2728
import org.apache.spark.{Logging, SecurityManager, SparkConf, SparkEnv, SparkException}
28-
29-
import scala.collection.JavaConversions.mapAsJavaMap
29+
import org.apache.spark.rpc.RpcTimeout
3030

3131
/**
3232
* Various utility classes for working with Akka.

core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -564,7 +564,7 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll {
564564
val rt2 = RpcTimeout(conf, Seq("spark.ask.invalid.timeout", testProp, secondaryProp), "1s")
565565
assert( testDurationSeconds === rt2.duration.toSeconds )
566566

567-
// Construct RpcTimeout with default value,
567+
// Construct RpcTimeout with default value,
568568
val defaultProp = "spark.ask.default.timeout"
569569
val defaultDurationSeconds = 1
570570
val rt3 = RpcTimeout(conf, Seq(defaultProp), defaultDurationSeconds.toString + "s")

core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,13 +22,13 @@ import scala.concurrent.ExecutionContext.Implicits.global
2222
import scala.concurrent.duration._
2323
import scala.language.postfixOps
2424

25-
import akka.actor.{ActorSystem, Actor, Props}
25+
import akka.actor.{Actor, ActorSystem, Props}
2626
import akka.pattern.ask
2727

28-
import com.typesafe.config.{ConfigValueFactory, ConfigFactory}
28+
import com.typesafe.config.{ConfigFactory, ConfigValueFactory}
2929

30-
import org.apache.spark.rpc._
3130
import org.apache.spark.{SecurityManager, SparkConf}
31+
import org.apache.spark.rpc._
3232

3333
class AkkaRpcEnvSuite extends RpcEnvSuite {
3434

0 commit comments

Comments
 (0)