File tree Expand file tree Collapse file tree
core/src/main/scala/org/apache/spark/util Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -201,22 +201,6 @@ private[spark] object Utils extends Logging {
201201 }
202202 }
203203
204- // Is the path already registered to be deleted via a shutdown hook ?
205- def hasShutdownDeleteDir (file : File ): Boolean = {
206- val absolutePath = file.getAbsolutePath()
207- shutdownDeletePaths.synchronized {
208- shutdownDeletePaths.contains(absolutePath)
209- }
210- }
211-
212- // Is the path already registered to be deleted via a shutdown hook ?
213- def hasShutdownDeleteTachyonDir (file : TachyonFile ): Boolean = {
214- val absolutePath = file.getPath()
215- shutdownDeletePaths.synchronized {
216- shutdownDeletePaths.contains(absolutePath)
217- }
218- }
219-
220204 // Note: if file is child of some registered path, while not equal to it, then return true;
221205 // else false. This is to ensure that two shutdown hooks do not try to delete each others
222206 // paths - resulting in IOException and incomplete cleanup.
You can’t perform that action at this time.
0 commit comments