We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5c61e40 commit 3fb8c8dCopy full SHA for 3fb8c8d
src/query/service/src/interpreters/interpreter_delete.rs
@@ -76,7 +76,8 @@ impl Interpreter for DeleteInterpreter {
76
if !pipeline.pipes.is_empty() {
77
let settings = self.ctx.get_settings();
78
pipeline.set_max_threads(settings.get_max_threads()? as usize);
79
- let executor_settings = ExecutorSettings::try_create(&settings)?;
+ let query_id = self.ctx.get_id();
80
+ let executor_settings = ExecutorSettings::try_create(&settings, query_id)?;
81
let executor = PipelineCompleteExecutor::try_create(pipeline, executor_settings)?;
82
83
self.ctx.set_executor(Arc::downgrade(&executor.get_inner()));
0 commit comments