Call correct stop().

aarondav · aarondav · commit 8d1446a5b8b6 · 2014-04-24T01:00:32.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala b/core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala
@@ -150,11 +150,12 @@ private[spark] class DiskBlockManager(shuffleManager: ShuffleBlockManager, rootD
     Runtime.getRuntime.addShutdownHook(new Thread("delete Spark local dirs") {
       override def run() {
         logDebug("Shutdown hook called")
-        stop()
+        DiskBlockManager.this.stop()
       }
     })
   }
 
+  /** Cleanup local dirs and stop shuffle sender. */
   private[spark] def stop() {
     localDirs.foreach { localDir =>
       if (localDir.isDirectory() && localDir.exists()) {

Original file line number	Diff line number	Diff line change
`@@ -150,11 +150,12 @@ private[spark] class DiskBlockManager(shuffleManager: ShuffleBlockManager, rootD`
`150`	`150`	`Runtime.getRuntime.addShutdownHook(new Thread("delete Spark local dirs") {`
`151`	`151`	`override def run() {`
`152`	`152`	`logDebug("Shutdown hook called")`
`153`		`- stop()`
	`153`	`+ DiskBlockManager.this.stop()`
`154`	`154`	`}`
`155`	`155`	`})`
`156`	`156`	`}`
`157`	`157`
	`158`	`+ /** Cleanup local dirs and stop shuffle sender. */`
`158`	`159`	`private[spark] def stop() {`
`159`	`160`	`localDirs.foreach { localDir =>`
`160`	`161`	`if (localDir.isDirectory() && localDir.exists()) {`