thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Delete pipeline when query is finished.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-05-13 20:02:54 +03:00
parent 9f943b739f
commit 4453327344
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dbms/programs/server/TCPHandler.cpp
View File

@ -510,8 +510,11 @@ void TCPHandler::processOrdinaryQueryWithProcessors(size_t num_threads)
}
});
/// Wait in case of exception.
SCOPE_EXIT(pool.wait());
/// Wait in case of exception. Delete pipeline to release memory.
SCOPE_EXIT(
pool.wait();
pipeline = QueryPipeline()
);
while (true)
{