check faster

CodingCat · CodingCat · commit c5dbaf54d5ef · 2025-05-14T10:46:13.000-07:00
diff --git a/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/fetch_failure/FetchFailureDiskCleanBase.scala b/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/fetch_failure/FetchFailureDiskCleanBase.scala
@@ -89,7 +89,7 @@ private[tests] trait FetchFailureDiskCleanBase extends AnyFunSuite
     override def run(): Unit = {
       var allDataInShape = checkDirStatus()
       while (!allDataInShape) {
-        Thread.sleep(1000)
+        Thread.sleep(100)
         allDataInShape = checkDirStatus()
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,7 @@ private[tests] trait FetchFailureDiskCleanBase extends AnyFunSuite`
`89`	`89`	`override def run(): Unit = {`
`90`	`90`	`var allDataInShape = checkDirStatus()`
`91`	`91`	`while (!allDataInShape) {`
`92`		`- Thread.sleep(1000)`
	`92`	`+ Thread.sleep(100)`
`93`	`93`	`allDataInShape = checkDirStatus()`
`94`	`94`	`}`
`95`	`95`	`}`