diff options
| author | Dmitriy Lyubimov <dlyubimov@apache.org> | 2013-07-27 23:08:00 -0700 |
|---|---|---|
| committer | Dmitriy Lyubimov <dlyubimov@apache.org> | 2013-07-27 23:08:00 -0700 |
| commit | f5067abe85922b8075e03f39a45e4ac39267c62e (patch) | |
| tree | 0d3cf12648153f22305b052e9f7fcd4da14c2ca2 /core | |
| parent | 6a47cee72104c9f6d264cb2e61ae8a38523cfdad (diff) | |
| download | spark-f5067abe85922b8075e03f39a45e4ac39267c62e.tar.gz spark-f5067abe85922b8075e03f39a45e4ac39267c62e.tar.bz2 spark-f5067abe85922b8075e03f39a45e4ac39267c62e.zip | |
changes per comments.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala b/core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala index 685fc016b2..d541234548 100644 --- a/core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala +++ b/core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala @@ -67,7 +67,7 @@ private[spark] class ClusterTaskSetManager( val CPUS_PER_TASK = System.getProperty("spark.task.cpus", "1").toDouble // Maximum times a task is allowed to fail before failing the job - val MAX_TASK_FAILURES = System.getProperty("spark.task.max.fail", "4").toInt + val MAX_TASK_FAILURES = System.getProperty("spark.task.maxFailures", "4").toInt // Quantile of tasks at which to start speculation val SPECULATION_QUANTILE = System.getProperty("spark.speculation.quantile", "0.75").toDouble |