From d0cef1dc3083d2e5d691c07d3055c30a842e4f00 Mon Sep 17 00:00:00 2001 From: Yadong Date: Fri, 18 Jul 2014 15:44:56 +0800 Subject: [PATCH 1/2] Update CoarseGrainedExecutorBackend.scala --- .../org/apache/spark/executor/CoarseGrainedExecutorBackend.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala index b455c9fcf4bd6..cc2631ab51824 100644 --- a/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala +++ b/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala @@ -90,6 +90,7 @@ private[spark] class CoarseGrainedExecutorBackend( logInfo("Driver commanded a shutdown") context.stop(self) context.system.shutdown() + SparkEnv.get.blockManager.diskBlockManager.stop() } override def statusUpdate(taskId: Long, state: TaskState, data: ByteBuffer) { From 8b8641bc25ed1f3c47cd4261720d24ddc622e6bc Mon Sep 17 00:00:00 2001 From: Yadong Date: Fri, 18 Jul 2014 15:45:22 +0800 Subject: [PATCH 2/2] Update MesosExecutorBackend.scala --- .../scala/org/apache/spark/executor/MesosExecutorBackend.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala index a42c8b43bbf7f..2ec745f3551d7 100644 --- a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala +++ b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala @@ -87,7 +87,7 @@ private[spark] class MesosExecutorBackend override def frameworkMessage(d: ExecutorDriver, data: Array[Byte]) {} - override def shutdown(d: ExecutorDriver) {} + override def shutdown(d: ExecutorDriver) {SparkEnv.get.blockManager.diskBlockManager.stop()} } /**