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

Fix build error in test

parent 30186aa2
No related branches found
No related tags found
No related merge requests found
...@@ -283,7 +283,7 @@ class TaskSetManagerSuite extends FunSuite with LocalSparkContext with Logging { ...@@ -283,7 +283,7 @@ class TaskSetManagerSuite extends FunSuite with LocalSparkContext with Logging {
// Fail the task MAX_TASK_FAILURES times, and check that the task set is aborted // Fail the task MAX_TASK_FAILURES times, and check that the task set is aborted
// after the last failure. // after the last failure.
(1 to manager.MAX_TASK_FAILURES).foreach { index => (1 to manager.maxTaskFailures).foreach { index =>
val offerResult = manager.resourceOffer("exec1", "host1", 1, ANY) val offerResult = manager.resourceOffer("exec1", "host1", 1, ANY)
assert(offerResult != None, assert(offerResult != None,
"Expect resource offer on iteration %s to return a task".format(index)) "Expect resource offer on iteration %s to return a task".format(index))
......
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