[Spark] Add sleep 1s for compaction tests (lakesoul-io#435)

Signed-off-by: chenxu <[email protected]> Co-authored-by: chenxu <[email protected]>
F-PHantam · Jan 27, 2024 · 304ab09 · 304ab09
1 parent 2fb4701
commit 304ab09
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/commands/CompactionSuite.scala b/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/commands/CompactionSuite.scala
@@ -230,6 +230,7 @@ class CompactionSuite extends QueryTest
       assert(!rangeInfo.groupBy(_.file_bucket_id).forall(_._2.length == 1))
 
       LakeSoulTable.forPath(tableName).compaction("range=1")
+      Thread.sleep(1000)
 
       val allDataInfo = SparkUtil.allDataInfo(sm.updateSnapshot())
       println(allDataInfo.mkString("Array(", ", ", ")"))
@@ -278,6 +279,7 @@ class CompactionSuite extends QueryTest
       * call LakeSoulTable.compaction(tableName=>'lakesoul',cleanOld=>true)
       */
       sql("call LakeSoulTable.compaction(condition=>map('range',1),tablePath=>'" + tableName + "')")
+      Thread.sleep(1000)
 
       val allDataInfo = SparkUtil.allDataInfo(sm.updateSnapshot())
       println(allDataInfo.mkString("Array(", ", ", ")"))