Updated Branches: refs/heads/master bfa68609d -> e0392343a
Removed redundant residual re: reverted refactoring. Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/94087c46 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/94087c46 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/94087c46 Branch: refs/heads/master Commit: 94087c463b41a92a9462b954f1f6452614569fe5 Parents: 982797d Author: Mark Hamstra <[email protected]> Authored: Wed Nov 20 15:47:30 2013 -0800 Committer: Mark Hamstra <[email protected]> Committed: Tue Dec 3 09:57:31 2013 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/94087c46/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index bf5827d..be46f74 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -384,7 +384,7 @@ class DAGScheduler( .format(jobId, stageId)) } else { jobSet -= jobId - if ((jobSet - jobId).isEmpty) { // no other job needs this stage + if (jobSet.isEmpty) { // no other job needs this stage p(stageId) } }
