diff --git a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala index e81cfb5b20..035ed4aa51 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala @@ -293,8 +293,7 @@ class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter { val textPath = new Path(generatedSubDir, "renamed.txt") write(textPath, "renamed\n") val now = clock.getTimeMillis() - val modTime = now + durationMs / 2 - fs.setTimes(textPath, modTime, modTime) + fs.setTimes(textPath, now, now) val textFilestatus = fs.getFileStatus(existingFile) assert(textFilestatus.getModificationTime < now + durationMs)