diff options
| author | linweizhong <linweizhong@huawei.com> | 2015-09-17 22:25:24 -0700 |
|---|---|---|
| committer | Yin Huai <yhuai@databricks.com> | 2015-09-17 22:25:24 -0700 |
| commit | 93c7650ab60a839a9cbe8b4ea1d5eda93e53ebe0 (patch) | |
| tree | 28526e76b146b64e848f590f3c6f3d848a332e9d /core/src | |
| parent | d009da2f5c803f3b7344c96abbfcf3ecef2f5ad2 (diff) | |
| download | spark-93c7650ab60a839a9cbe8b4ea1d5eda93e53ebe0.tar.gz spark-93c7650ab60a839a9cbe8b4ea1d5eda93e53ebe0.tar.bz2 spark-93c7650ab60a839a9cbe8b4ea1d5eda93e53ebe0.zip | |
[SPARK-9522] [SQL] SparkSubmit process can not exit if kill application when HiveThriftServer was starting
When we start HiveThriftServer, we will start SparkContext first, then start HiveServer2, if we kill application while HiveServer2 is starting then SparkContext will stop successfully, but SparkSubmit process can not exit.
Author: linweizhong <linweizhong@huawei.com>
Closes #7853 from Sephiroth-Lin/SPARK-9522.
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index 9c3218719f..ebd8e946ee 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -97,7 +97,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli val startTime = System.currentTimeMillis() - private val stopped: AtomicBoolean = new AtomicBoolean(false) + private[spark] val stopped: AtomicBoolean = new AtomicBoolean(false) private def assertNotStopped(): Unit = { if (stopped.get()) { |