aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorAaron Davidson <aaron@databricks.com>2013-12-19 17:53:41 -0800
committerAaron Davidson <aaron@databricks.com>2013-12-19 17:53:41 -0800
commit4d74b899b7daff74054b70f38cddf7b38fe6c211 (patch)
tree0cfe25cb08ff24b6b72d6867720213dcc83788f8 /core
parent1ab031eaff7fb2473adb3e909a7a969e9cd28b49 (diff)
downloadspark-4d74b899b7daff74054b70f38cddf7b38fe6c211.tar.gz
spark-4d74b899b7daff74054b70f38cddf7b38fe6c211.tar.bz2
spark-4d74b899b7daff74054b70f38cddf7b38fe6c211.zip
Remove firstApp from the standalone scheduler Master
As a lonely child with no one to care for it... we had to put it down.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/deploy/master/Master.scala10
1 files changed, 0 insertions, 10 deletions
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 7b2b1c3327..eebd0794b8 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
@@ -61,8 +61,6 @@ private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Act
val waitingApps = new ArrayBuffer[ApplicationInfo]
val completedApps = new ArrayBuffer[ApplicationInfo]
- var firstApp: Option[ApplicationInfo] = None
-
Utils.checkHost(host, "Expected hostname")
val masterMetricsSystem = MetricsSystem.createMetricsSystem("master")
@@ -441,14 +439,6 @@ private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Act
idToApp(app.id) = app
actorToApp(app.driver) = app
addressToApp(appAddress) = app
- if (firstApp == None) {
- firstApp = Some(app)
- }
- // TODO: What is firstApp?? Can we remove it?
- val workersAlive = workers.filter(_.state == WorkerState.ALIVE).toArray
- if (workersAlive.size > 0 && !workersAlive.exists(_.memoryFree >= app.desc.memoryPerSlave)) {
- logWarning("Could not find any workers with enough memory for " + firstApp.get.id)
- }
waitingApps += app
}