Skip to content

Commit 15ac573

Browse files
committed
temp, use for test
1 parent 95a2451 commit 15ac573

File tree

2 files changed

+4
-11
lines changed

2 files changed

+4
-11
lines changed

src/query/service/src/global_services.rs

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

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

173171
Self::init_workload_mgr(config).await?;
174172

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

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

1818
use databend_common_catalog::table_context::TableContext;
19-
use databend_common_config::GlobalConfig;
2019
use databend_common_exception::Result;
2120

2221
#[derive(Clone)]
@@ -35,15 +34,11 @@ impl ExecutorSettings {
3534
let max_threads = settings.get_max_threads()?;
3635
let max_execute_time_in_seconds = settings.get_max_execute_time_in_seconds()?;
3736

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()?;
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()?;
4039
// If `use_legacy_query_executor` is set to 1, we disable the queries executor
4140
// Otherwise, we all follow configuration
42-
let enable_queries_executor = if setting_use_legacy_query_executor {
43-
false
44-
} else {
45-
config_enable_queries_executor
46-
};
41+
let enable_queries_executor = true;
4742

4843
Ok(ExecutorSettings {
4944
enable_queries_executor,

0 commit comments

Comments
 (0)