aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorAli Ghodsi <alig@cs.berkeley.edu>2013-09-03 00:56:12 -0700
committerAli Ghodsi <alig@cs.berkeley.edu>2013-09-03 00:56:12 -0700
commitb25918d8412eb314587e03b727dd1d6c99947669 (patch)
tree68b1e724271d19eaafd9217dfe114d39df671807 /core
parentbd0788505f4ebac37a3cdf4753589deb58455c1b (diff)
parentcbfef9b3ffadbdb8e39d092a97090de5ffd7c1dd (diff)
downloadspark-b25918d8412eb314587e03b727dd1d6c99947669.tar.gz
spark-b25918d8412eb314587e03b727dd1d6c99947669.tar.bz2
spark-b25918d8412eb314587e03b727dd1d6c99947669.zip
Merge branch 'master' of https://github.com/alig/spark
Conflicts: core/src/main/scala/org/apache/spark/deploy/master/Master.scala
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala2
-rw-r--r--core/src/main/scala/org/apache/spark/deploy/master/Master.scala8
2 files changed, 5 insertions, 5 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala b/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala
index b8856e6e00..1cfff5e565 100644
--- a/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala
@@ -129,6 +129,6 @@ private[deploy] object DeployMessages {
case object RequestWebUIPort
- case class WebUIPortResponse(webUIBoundPort: Int) {}
+ case class WebUIPortResponse(webUIBoundPort: Int)
}
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
index e918a33d09..bde59905bc 100644
--- a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -17,17 +17,18 @@
package org.apache.spark.deploy.master
-import java.text.SimpleDateFormat
import java.util.Date
+import java.text.SimpleDateFormat
import scala.collection.mutable.{ArrayBuffer, HashMap, HashSet}
import akka.actor._
import akka.actor.Terminated
-import akka.remote.{RemoteClientLifeCycleEvent, RemoteClientDisconnected, RemoteClientShutdown}
-import akka.util.duration._
import akka.dispatch.Await
import akka.pattern.ask
+import akka.remote.{RemoteClientLifeCycleEvent, RemoteClientDisconnected, RemoteClientShutdown}
+import akka.util.duration._
+import akka.util.Timeout
import org.apache.spark.{Logging, SparkException}
import org.apache.spark.deploy.{ApplicationDescription, ExecutorState}
@@ -36,7 +37,6 @@ import org.apache.spark.deploy.master.ui.MasterWebUI
import org.apache.spark.metrics.MetricsSystem
import org.apache.spark.util.{Utils, AkkaUtils}
import akka.util.{Duration, Timeout}
-import java.util.concurrent.TimeUnit
private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Actor with Logging {