Skip to content
Snippets Groups Projects
Commit d0588bd6 authored by Charles Reiss's avatar Charles Reiss
Browse files

Catch/log errors deleting temp dirs

parent 687581c3
No related branches found
No related tags found
No related merge requests found
......@@ -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)
}
}
})
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment