Skip to content

Commit

Permalink
[SPARK-6980] Cleaned up import ordering
Browse files Browse the repository at this point in the history
  • Loading branch information
BryanCutler committed Jun 12, 2015
1 parent 08f5afc commit 1b9beab
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
6 changes: 3 additions & 3 deletions core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down

0 comments on commit 1b9beab

Please sign in to comment.