Skip to content

Commit 80afc79

Browse files
jiangxb1987dongjoon-hyun
authored andcommitted
[SPARK-29263][SCHEDULER][FOLLOWUP][TEST] Update FakeTask.createTaskSet() method
### What changes were proposed in this pull request? Update `FakeTask.createTaskSet()` method to make the generated TaskSet makes use of the `priority` param. ### How was this patch tested? All the places referring to this method pass `priority = 0`, but we still need to fix this to avoid future test failure. Closes apache#26030 from jiangxb1987/SPARK-292630-FOLLOWUP. Authored-by: Xingbo Jiang <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
1 parent 8556710 commit 80afc79

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/test/scala/org/apache/spark/scheduler/FakeTask.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ object FakeTask {
6565
val tasks = Array.tabulate[Task[_]](numTasks) { i =>
6666
new FakeTask(stageId, i, if (prefLocs.size != 0) prefLocs(i) else Nil)
6767
}
68-
new TaskSet(tasks, stageId, stageAttemptId, priority = 0, null)
68+
new TaskSet(tasks, stageId, stageAttemptId, priority = priority, null)
6969
}
7070

7171
def createShuffleMapTaskSet(

0 commit comments

Comments
 (0)