diff options
| author | Mark Hamstra <markhamstra@gmail.com> | 2013-11-20 15:47:30 -0800 |
|---|---|---|
| committer | Mark Hamstra <markhamstra@gmail.com> | 2013-12-03 09:57:31 -0800 |
| commit | 94087c463b41a92a9462b954f1f6452614569fe5 (patch) | |
| tree | 5b8347b10eba3f7d7ba6e36b7d6be4d9e36ebc53 /core | |
| parent | 982797dcbafa4c1149ad354b0c5a07e3f74fe005 (diff) | |
| download | spark-94087c463b41a92a9462b954f1f6452614569fe5.tar.gz spark-94087c463b41a92a9462b954f1f6452614569fe5.tar.bz2 spark-94087c463b41a92a9462b954f1f6452614569fe5.zip | |
Removed redundant residual re: reverted refactoring.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 bf5827d011..be46f74f7c 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) } } |