diff options
author | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 15:38:58 -0600 |
---|---|---|
committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 15:38:58 -0600 |
commit | 6f2194f7576eb188c23f18125f5101ae0b4e9e4d (patch) | |
tree | bbd85f8696dc878dceff174bcfe86092422371b7 /core | |
parent | d1de9d7d15591d13c3ae27721f9926e94f7b6cf0 (diff) | |
download | spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.tar.gz spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.tar.bz2 spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.zip |
Call removeJob instead of killing the cluster.
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 2c2cd0231b..d1a65204b8 100644 --- a/core/src/main/scala/spark/deploy/master/Master.scala +++ b/core/src/main/scala/spark/deploy/master/Master.scala @@ -103,8 +103,7 @@ private[spark] class Master(ip: String, port: Int, webUiPort: Int) extends Actor val e = new SparkException("Job %s wth ID %s failed %d times.".format( jobInfo.desc.name, jobInfo.id, jobInfo.retryCount)) logError(e.getMessage, e) - throw e - //System.exit(1) + removeJob(jobInfo) } } } |