From 8dc9cb54d5b46031b648cd81cc8761597e1ef31c Mon Sep 17 00:00:00 2001 From: Kelvin Chu Date: Wed, 2 Apr 2014 01:28:04 -0700 Subject: [PATCH] Fixed a bug in Utils.findOldFiles() after merge. --- core/src/main/scala/org/apache/spark/util/Utils.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 559cd7f00471b..d3b57d79e8fad 100644 --- 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) }