temp table uses fuse engine if cluster mode

databendlabs · Nov 27, 2024 · 9df1f02 · 9df1f02
1 parent d8ec530
commit 9df1f02
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/query/sql/src/planner/binder/bind_query/bind.rs b/src/query/sql/src/planner/binder/bind_query/bind.rs
@@ -178,7 +178,9 @@ impl Binder {
     }
 
     fn m_cte_to_temp_table(&self, cte: &CTE) -> Result<()> {
-        let engine = if self.ctx.get_settings().get_persist_materialized_cte()? {
+        let engine = if self.ctx.get_settings().get_persist_materialized_cte()?
+            || !self.ctx.get_cluster().is_empty()
+        {
             Engine::Fuse
         } else {
             Engine::Memory