Skip to content
Snippets Groups Projects
Commit b25918d8 authored by Ali Ghodsi's avatar Ali Ghodsi
Browse files

Merge branch 'master' of https://github.com/alig/spark

Conflicts:
	core/src/main/scala/org/apache/spark/deploy/master/Master.scala
parents bd078850 cbfef9b3
No related branches found
No related tags found
No related merge requests found
......@@ -129,6 +129,6 @@ private[deploy] object DeployMessages {
case object RequestWebUIPort
case class WebUIPortResponse(webUIBoundPort: Int) {}
case class WebUIPortResponse(webUIBoundPort: Int)
}
......@@ -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 {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment