fix Compaction suite

Signed-off-by: zenghua <[email protected]>
lakesoul-io · Feb 7, 2024 · cf83977 · cf83977
1 parent b5f1f74
commit cf83977
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 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,7 +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)
+      Thread.sleep(3000)
 
       val allDataInfo = SparkUtil.allDataInfo(sm.updateSnapshot())
       println(allDataInfo.mkString("Array(", ", ", ")"))
@@ -279,7 +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)
+      Thread.sleep(3000)
 
       val allDataInfo = SparkUtil.allDataInfo(sm.updateSnapshot())
       println(allDataInfo.mkString("Array(", ", ", ")"))

diff --git a/rust/lakesoul-datafusion/src/lakesoul_table/mod.rs b/rust/lakesoul-datafusion/src/lakesoul_table/mod.rs
@@ -7,7 +7,6 @@ pub mod helpers;
 use std::{ops::Deref, sync::Arc};
 
 use arrow::datatypes::{SchemaRef, Schema};
-use datafusion::dataframe;
 use datafusion::sql::TableReference;
 use datafusion::{
     dataframe::DataFrame,