Skip to content
Snippets Groups Projects
Commit 19da82c5 authored by Kay Ousterhout's avatar Kay Ousterhout
Browse files

Fixed bug where task set managers are added to queue twice

This bug leads to a small performance hit because task
set managers will get offered each rejected resource
offer twice, but doesn't lead to any incorrect functionality.
parent 749f8428
No related branches found
No related tags found
No related merge requests found
...@@ -592,7 +592,7 @@ private[spark] class TaskSetManager( ...@@ -592,7 +592,7 @@ private[spark] class TaskSetManager(
override def removeSchedulable(schedulable: Schedulable) {} override def removeSchedulable(schedulable: Schedulable) {}
override def getSortedTaskSetQueue(): ArrayBuffer[TaskSetManager] = { override def getSortedTaskSetQueue(): ArrayBuffer[TaskSetManager] = {
var sortedTaskSetQueue = ArrayBuffer[TaskSetManager](this) var sortedTaskSetQueue = new ArrayBuffer[TaskSetManager]()
sortedTaskSetQueue += this sortedTaskSetQueue += this
sortedTaskSetQueue sortedTaskSetQueue
} }
......
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