We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8dc9cb5 commit 553d8c2Copy full SHA for 553d8c2
core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -542,10 +542,10 @@ private[spark] object Utils extends Logging {
542
* @param cutoff measured in seconds. Files older than this are returned.
543
*/
544
def findOldFiles(dir: File, cutoff: Long): Seq[File] = {
545
- val currentTimeSecs = System.currentTimeMillis
+ val currentTimeMillis = System.currentTimeMillis
546
if (dir.isDirectory) {
547
val files = listFilesSafely(dir)
548
- files.filter { file => file.lastModified < (currentTimeSecs - cutoff * 1000) }
+ files.filter { file => file.lastModified < (currentTimeMillis - cutoff * 1000) }
549
} else {
550
throw new IllegalArgumentException(dir + " is not a directory!")
551
}
0 commit comments