Fixed a bug in Utils.findOldFiles() after merge.

andrewor14 · Apr 3, 2014 · 8dc9cb5 · 8dc9cb5
1 parent cb52f2b
commit 8dc9cb5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -542,7 +542,7 @@ private[spark] object Utils extends Logging {
    * @param cutoff measured in seconds. Files older than this are returned.
    */
   def findOldFiles(dir: File, cutoff: Long): Seq[File] = {
-    val currentTimeSecs = System.currentTimeMillis / 1000
+    val currentTimeSecs = System.currentTimeMillis
     if (dir.isDirectory) {
       val files = listFilesSafely(dir)
       files.filter { file => file.lastModified < (currentTimeSecs - cutoff * 1000) }