Skip to content

Commit 6f5d941

Browse files
authored
fix: session leak when execute explain pipeline in cluster mode (#17572)
* reproduce * fix: session leak when execute explain pipeline in cluster mode
1 parent 6da4456 commit 6f5d941

File tree

2 files changed

+28
-0
lines changed

2 files changed

+28
-0
lines changed

src/query/service/src/interpreters/interpreter_explain.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,10 @@ impl Interpreter for ExplainInterpreter {
222222
let _ = pipeline.main_pipeline.take_on_init();
223223
let _ = pipeline.main_pipeline.take_on_finished();
224224

225+
self.ctx
226+
.get_exchange_manager()
227+
.on_finished_query(&self.ctx.get_id(), None);
228+
225229
for pipeline in &mut pipeline.sources_pipelines {
226230
let _ = pipeline.take_on_init();
227231
let _ = pipeline.take_on_finished();
Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
statement ok
2+
create or replace table t17248(a integer, b integer, c integer, d integer, e integer)
3+
4+
statement ok
5+
EXPLAIN PIPELINE SELECT (SELECT COUNT(*) FROM t17248 AS x WHERE x.b < t17248.b) AS col1 FROM t17248 WHERE a > b - 2 AND a < b + 2 OR c > d ORDER BY col1;
6+
7+
statement ok
8+
EXPLAIN PIPELINE SELECT * FROM t17248 ORDER BY a;
9+
10+
statement ok
11+
select avg(number) from numbers(10000000);
12+
13+
query T
14+
select count(*) from system.processes where extra_info like 'EXPLAIN PIPELINE SELECT (SELECT COUNT(*) FROM t17248%';
15+
----
16+
0
17+
18+
query T
19+
select count(*) from system.processes where extra_info like 'EXPLAIN PIPELINE SELECT * FROM t17248 ORDER BY a%';
20+
----
21+
0
22+
23+
statement ok
24+
drop table t17248;

0 commit comments

Comments
 (0)