You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2016/10/27 08:00:43 UTC
spark git commit: [SPARK-CORE][TEST][MINOR] Fix the wrong comment in
test
Repository: spark
Updated Branches:
refs/heads/master 44c8bfda7 -> 701a9d361
[SPARK-CORE][TEST][MINOR] Fix the wrong comment in test
## What changes were proposed in this pull request?
While learning core scheduler code, I found two lines of wrong comments. This PR simply corrects the comments.
## How was this patch tested?
Author: wm624@hotmail.com <wm...@hotmail.com>
Closes #15631 from wangmiao1981/Rbug.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/701a9d36
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/701a9d36
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/701a9d36
Branch: refs/heads/master
Commit: 701a9d361b3045a25c42b3c0e44e7755d45ff78c
Parents: 44c8bfd
Author: wm624@hotmail.com <wm...@hotmail.com>
Authored: Thu Oct 27 10:00:37 2016 +0200
Committer: Sean Owen <so...@cloudera.com>
Committed: Thu Oct 27 10:00:37 2016 +0200
----------------------------------------------------------------------
.../scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/701a9d36/core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala
index b49ba08..1b1a764 100644
--- a/core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala
@@ -261,14 +261,14 @@ class TaskSetManagerSuite extends SparkFunSuite with LocalSparkContext with Logg
assert(manager.resourceOffer("exec1", "host1", PROCESS_LOCAL) == None)
clock.advance(LOCALITY_WAIT_MS)
- // Offer host1, exec1 again, at NODE_LOCAL level: the node local (task 2) should
+ // Offer host1, exec1 again, at NODE_LOCAL level: the node local (task 3) should
// get chosen before the noPref task
assert(manager.resourceOffer("exec1", "host1", NODE_LOCAL).get.index == 2)
- // Offer host2, exec3 again, at NODE_LOCAL level: we should choose task 2
+ // Offer host2, exec2, at NODE_LOCAL level: we should choose task 2
assert(manager.resourceOffer("exec2", "host2", NODE_LOCAL).get.index == 1)
- // Offer host2, exec3 again, at NODE_LOCAL level: we should get noPref task
+ // Offer host2, exec2 again, at NODE_LOCAL level: we should get noPref task
// after failing to find a node_Local task
assert(manager.resourceOffer("exec2", "host2", NODE_LOCAL) == None)
clock.advance(LOCALITY_WAIT_MS)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org