fix test

databendlabs · May 24, 2024 · 7dc64d8 · 7dc64d8
1 parent 68fe1b0
commit 7dc64d8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/query/service/src/interpreters/interpreter_table_optimize.rs b/src/query/service/src/interpreters/interpreter_table_optimize.rs
@@ -298,6 +298,8 @@ async fn purge(
     let table = catalog
         .get_table(&ctx.get_tenant(), &plan.database, &plan.table)
         .await?;
+    // check mutability
+    table.check_mutable()?;
 
     let keep_latest = true;
     let res = table

diff --git a/src/query/service/src/sessions/query_ctx.rs b/src/query/service/src/sessions/query_ctx.rs
@@ -334,6 +334,9 @@ impl QueryContext {
         let tbl = catalog
             .get_table(&self.get_tenant(), db_name, tbl_name)
             .await?;
+        if tbl.engine() != "FUSE" {
+            return Ok(None);
+        }
 
         // Add table lock.
         let table_lock = LockManager::create_table_lock(tbl.get_table_info().clone())?;
@@ -356,6 +359,9 @@ impl QueryContext {
         let tbl = catalog
             .get_table(&self.get_tenant(), db_name, tbl_name)
             .await?;
+        if tbl.engine() != "FUSE" {
+            return Ok(None);
+        }
 
         // Add table lock.
         let table_lock = LockManager::create_table_lock(tbl.get_table_info().clone())?;