thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 23:52:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Wait for pipeline to be destroyed in case of exception

Browse Source
This commit is contained in:
Nikolai Kochetov 2022-02-03 12:14:33 +00:00
parent 2003a96b58
commit 244bb984e6
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/QueryPipeline/BlockIO.h
View File

@ -40,10 +40,12 @@ struct BlockIO
pipeline.reset();
}
void onException() const
void onException()
{
if (exception_callback)
exception_callback();
pipeline.reset();
}
private: