From eaf616922e231dac2b47193d593dac3f5e585c2e Mon Sep 17 00:00:00 2001 From: Madhusudanan Kandasamy Date: Mon, 14 Sep 2015 21:52:12 +0530 Subject: [PATCH 1/2] [SPARK-10458] [Spark Core] Added isStopped() method in SparkContext --- core/src/main/scala/org/apache/spark/SparkContext.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index e27b3c4962221..a32e49ed8599a 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -264,6 +264,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli val tachyonFolderName = externalBlockStoreFolderName def isLocal: Boolean = (master == "local" || master.startsWith("local[")) + def isStopped: Boolean = stopped.get() // An asynchronous listener bus for Spark events private[spark] val listenerBus = new LiveListenerBus From 87b4ce5c5db41e31e1c3f97e122a1443ebc5b518 Mon Sep 17 00:00:00 2001 From: Madhusudanan Kandasamy Date: Mon, 21 Sep 2015 09:20:52 +0530 Subject: [PATCH 2/2] [SPARK-10458] [Spark Core] Added scaladoc for isStopped() method in SparkContext --- core/src/main/scala/org/apache/spark/SparkContext.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index a32e49ed8599a..f69a6b8f02492 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -264,6 +264,9 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli val tachyonFolderName = externalBlockStoreFolderName def isLocal: Boolean = (master == "local" || master.startsWith("local[")) + /** + * @return true if context is stopped or in the midst of stopping. + */ def isStopped: Boolean = stopped.get() // An asynchronous listener bus for Spark events