fix issue

apache · Feb 25, 2015 · 71782b5 · 71782b5
1 parent 5b45035
commit 71782b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala
@@ -277,7 +277,7 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
       // Only directories older than now maxAge milliseconds mill will be deleted
       statusList.foreach { dir =>
         try {
-          if (now - getModificationTime(dir) > maxAge) {
+          if (now - dir.getModificationTime() > maxAge) {
             fs.delete(dir.getPath, true)
           }
         } catch {