thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Review fix.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-09-04 15:54:31 +03:00
parent 13e0464138
commit 7f88e3de1f
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Processors/Executors/PipelineExecutor.cpp
View File

@ -402,6 +402,11 @@ void PipelineExecutor::execute(size_t num_threads)
for (auto & node : graph->nodes)
if (node->exception)
std::rethrow_exception(node->exception);
/// Exception which happened in executing thread, but not at processor.
for (auto & executor_context : executor_contexts)
if (executor_context->exception)
std::rethrow_exception(executor_context->exception);
}
catch (...)
{
@ -432,11 +437,6 @@ bool PipelineExecutor::executeStep(std::atomic_bool * yield_flag)
if (node->exception)
std::rethrow_exception(node->exception);
/// Exception which happened in executing thread, but not at processor.
for (auto & executor_context : executor_contexts)
if (executor_context->exception)
std::rethrow_exception(executor_context->exception);
finalizeExecution();
return false;