diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 18:09:10 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 18:09:10 -0600 |
| commit | 8c51322cd05f2ae97a08c3af314c7608fcf71b57 (patch) | |
| tree | eae7b9fa7db194ee056bfb5a64e91c8fff5d2d9d /core | |
| parent | 250fe89679bb59ef0d31f74985f72556dcfe2d06 (diff) | |
| download | spark-8c51322cd05f2ae97a08c3af314c7608fcf71b57.tar.gz spark-8c51322cd05f2ae97a08c3af314c7608fcf71b57.tar.bz2 spark-8c51322cd05f2ae97a08c3af314c7608fcf71b57.zip | |
Don't bother creating an exception.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/deploy/master/Master.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/deploy/master/Master.scala b/core/src/main/scala/spark/deploy/master/Master.scala index d1a65204b8..361e5ac627 100644 --- a/core/src/main/scala/spark/deploy/master/Master.scala +++ b/core/src/main/scala/spark/deploy/master/Master.scala @@ -100,9 +100,8 @@ private[spark] class Master(ip: String, port: Int, webUiPort: Int) extends Actor if (jobInfo.incrementRetryCount <= JobState.MAX_NUM_RETRY) { schedule() } else { - val e = new SparkException("Job %s wth ID %s failed %d times.".format( + logError("Job %s wth ID %s failed %d times, removing it".format( jobInfo.desc.name, jobInfo.id, jobInfo.retryCount)) - logError(e.getMessage, e) removeJob(jobInfo) } } |