diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-08-02 19:11:17 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-08-02 19:11:17 -0700 |
| commit | c22043f15062f0d0bd364ede4810ffd96babb088 (patch) | |
| tree | c4cbdfbb181cb141de94c9829d6e5e7cb013e519 /core | |
| parent | f6c8c2a3948c40977702d48647f17664fc4daf2b (diff) | |
| download | spark-c22043f15062f0d0bd364ede4810ffd96babb088.tar.gz spark-c22043f15062f0d0bd364ede4810ffd96babb088.tar.bz2 spark-c22043f15062f0d0bd364ede4810ffd96babb088.zip | |
Minor fix: can use >= when checking memory
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/MesosScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/MesosScheduler.scala b/core/src/main/scala/spark/MesosScheduler.scala index 9ca316d953..2484ca8f79 100644 --- a/core/src/main/scala/spark/MesosScheduler.scala +++ b/core/src/main/scala/spark/MesosScheduler.scala @@ -190,7 +190,7 @@ extends MScheduler with DAGScheduler with Logging val enoughMem = offers.map(o => { val mem = getResource(o.getResourcesList(), "mem") val slaveId = o.getSlaveId.getValue - mem > EXECUTOR_MEMORY || slavesWithExecutors.contains(slaveId) + mem >= EXECUTOR_MEMORY || slavesWithExecutors.contains(slaveId) }) var launchedTask = false for (job <- activeJobsQueue) { |