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 | |
| parent | d1de9d7d15591d13c3ae27721f9926e94f7b6cf0 (diff) | |
| download | spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.tar.gz spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.tar.bz2 spark-6f2194f7576eb188c23f18125f5101ae0b4e9e4d.zip | |
Call removeJob instead of killing the cluster.
| -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) } } } |