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

Signed-off-by: chenxu <chenxu@dmetasoul.com> Co-authored-by: chenxu <chenxu@dmetasoul.com>
mag1c1an1 · Jan 29, 2024 · 124db9a · 124db9a
1 parent 83a5312
commit 124db9a
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(", ", ", ")"))