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

Add processlist to PipelineExecutor. Throw exception if query was killed.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-01-28 16:16:02 +03:00
parent 5a8a367228
commit fea33f8b60
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dbms/src/Processors/Executors/PipelineExecutor.cpp
View File

@ -474,13 +474,11 @@ void PipelineExecutor::execute(size_t num_threads)
throw;
}
if (cancelled)
{
if (process_list_element && process_list_element->isKilled())
throw Exception("Query was cancelled", ErrorCodes::QUERY_WAS_CANCELLED);
if (process_list_element && process_list_element->isKilled())
throw Exception("Query was cancelled", ErrorCodes::QUERY_WAS_CANCELLED);
if (cancelled)
return;
}
bool all_processors_finished = true;
for (auto & node : graph)