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) }