From dd2e98b505712ca60e86b4c175674e2029f21de4 Mon Sep 17 00:00:00 2001 From: xudong963 Date: Thu, 5 Dec 2024 11:37:33 +0800 Subject: [PATCH 1/2] chore: test ci benchmark --- src/query/sql/src/planner/binder/bind_query/bind.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/query/sql/src/planner/binder/bind_query/bind.rs b/src/query/sql/src/planner/binder/bind_query/bind.rs index 94386ce8b817c..f90d1bc13a24e 100644 --- a/src/query/sql/src/planner/binder/bind_query/bind.rs +++ b/src/query/sql/src/planner/binder/bind_query/bind.rs @@ -186,6 +186,7 @@ impl Binder { } else { Engine::Memory }; + let database = self.ctx.get_current_database(); let table_name = normalize_identifier(&cte.alias.name, &self.name_resolution_ctx).name; if self From c755441d994f25c1803c0a3a0700b87709d28a74 Mon Sep 17 00:00:00 2001 From: xudong963 Date: Tue, 10 Dec 2024 15:36:54 +0800 Subject: [PATCH 2/2] cluster use fuse --- Cargo.lock | 3 +-- src/query/sql/src/planner/binder/bind_query/bind.rs | 4 +++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index b135d630e2d25..cbc30a7365b8d 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -4130,7 +4130,6 @@ dependencies = [ name = "databend-common-storages-factory" version = "0.1.0" dependencies = [ - "async-trait", "dashmap 6.1.0", "databend-common-catalog", "databend-common-config", @@ -4145,7 +4144,6 @@ dependencies = [ "databend-common-storages-stream", "databend-common-storages-view", "databend-storages-common-index", - "tokio", ] [[package]] @@ -4531,6 +4529,7 @@ dependencies = [ "databend-common-exception", "databend-common-expression", "databend-common-functions", + "databend-common-management", "databend-common-meta-api", "databend-common-meta-app", "databend-common-meta-types", diff --git a/src/query/sql/src/planner/binder/bind_query/bind.rs b/src/query/sql/src/planner/binder/bind_query/bind.rs index f90d1bc13a24e..28068f5d6620f 100644 --- a/src/query/sql/src/planner/binder/bind_query/bind.rs +++ b/src/query/sql/src/planner/binder/bind_query/bind.rs @@ -181,7 +181,9 @@ impl Binder { // The return value is temp_table name` 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