Skip to content

Commit 4c67569

Browse files
committed
Revert "temp, use for test"
This reverts commit 5696744.
1 parent 5696744 commit 4c67569

File tree

2 files changed

+11
-4
lines changed

2 files changed

+11
-4
lines changed

src/query/service/src/global_services.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,9 @@ impl GlobalServices {
166166
DummyResourcesManagement::init()?;
167167
}
168168

169-
GlobalQueriesExecutor::init()?;
169+
if config.query.enable_queries_executor {
170+
GlobalQueriesExecutor::init()?;
171+
}
170172

171173
Self::init_workload_mgr(config).await?;
172174

src/query/service/src/pipelines/executor/executor_settings.rs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ use std::sync::Arc;
1616
use std::time::Duration;
1717

1818
use databend_common_catalog::table_context::TableContext;
19+
use databend_common_config::GlobalConfig;
1920
use databend_common_exception::Result;
2021

2122
#[derive(Clone)]
@@ -34,11 +35,15 @@ impl ExecutorSettings {
3435
let max_threads = settings.get_max_threads()?;
3536
let max_execute_time_in_seconds = settings.get_max_execute_time_in_seconds()?;
3637

37-
// let config_enable_queries_executor = GlobalConfig::instance().query.enable_queries_executor;
38-
// let setting_use_legacy_query_executor = settings.get_use_legacy_query_executor()?;
38+
let config_enable_queries_executor = GlobalConfig::instance().query.enable_queries_executor;
39+
let setting_use_legacy_query_executor = settings.get_use_legacy_query_executor()?;
3940
// If `use_legacy_query_executor` is set to 1, we disable the queries executor
4041
// Otherwise, we all follow configuration
41-
let enable_queries_executor = true;
42+
let enable_queries_executor = if setting_use_legacy_query_executor {
43+
false
44+
} else {
45+
config_enable_queries_executor
46+
};
4247

4348
Ok(ExecutorSettings {
4449
enable_queries_executor,

0 commit comments

Comments
 (0)