diff options
| author | Daniel Darabos <darabos.daniel@gmail.com> | 2015-06-04 13:46:49 +0200 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-06-04 13:46:49 +0200 |
| commit | 10ba1880878d0babcdc5c9b688df5458ea131531 (patch) | |
| tree | d524f56e141a332d784119dff4adc2b4b746bae9 /core | |
| parent | 9982d453c39e50aedae7d01e4c38fab1b2bc6be0 (diff) | |
| download | spark-10ba1880878d0babcdc5c9b688df5458ea131531.tar.gz spark-10ba1880878d0babcdc5c9b688df5458ea131531.tar.bz2 spark-10ba1880878d0babcdc5c9b688df5458ea131531.zip | |
Fix maxTaskFailures comment
If maxTaskFailures is 1, the task set is aborted after 1 task failure. Other documentation and the code supports this reading, I think it's just this comment that was off. It's easy to make this mistake — can you please double-check if I'm correct? Thanks!
Author: Daniel Darabos <darabos.daniel@gmail.com>
Closes #6621 from darabos/patch-2 and squashes the following commits:
dfebdec [Daniel Darabos] Fix comment.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala index 673cd0e19e..82455b0426 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -46,7 +46,7 @@ import org.apache.spark.util.{Clock, SystemClock, Utils} * * @param sched the TaskSchedulerImpl associated with the TaskSetManager * @param taskSet the TaskSet to manage scheduling for - * @param maxTaskFailures if any particular task fails more than this number of times, the entire + * @param maxTaskFailures if any particular task fails this number of times, the entire * task set will be aborted */ private[spark] class TaskSetManager( |