diff options
author | Charles Reiss <charles@eecs.berkeley.edu> | 2013-02-19 11:53:01 -0800 |
---|---|---|
committer | Charles Reiss <charles@eecs.berkeley.edu> | 2013-02-19 13:04:06 -0800 |
commit | d0588bd6d7da3ba5adaba24303ad8616bdc2484f (patch) | |
tree | 1fa4e7373346adbaae1d012d6f863608564a06b6 /core | |
parent | 687581c3ec2b6b8310bd5be9f2d15b25b9051aac (diff) | |
download | spark-d0588bd6d7da3ba5adaba24303ad8616bdc2484f.tar.gz spark-d0588bd6d7da3ba5adaba24303ad8616bdc2484f.tar.bz2 spark-d0588bd6d7da3ba5adaba24303ad8616bdc2484f.zip |
Catch/log errors deleting temp dirs
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index 7e5b820cbb..ddbf8821ad 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -178,7 +178,11 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) Runtime.getRuntime.addShutdownHook(new Thread("delete Spark local dirs") { override def run() { logDebug("Shutdown hook called") - localDirs.foreach(localDir => Utils.deleteRecursively(localDir)) + try { + localDirs.foreach(localDir => Utils.deleteRecursively(localDir)) + } catch { + case t: Throwable => logError("Exception while deleting local spark dirs", t) + } } }) } |