Backport #60499 to 23.12: Cancel PipelineExecutor properly in case of…

… exception in spawnThreads
ClickHouse · Mar 13, 2024 · 69e8829 · 69e8829
1 parent d276f88
commit 69e8829
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Processors/Executors/PipelineExecutor.cpp b/src/Processors/Executors/PipelineExecutor.cpp
@@ -391,7 +391,9 @@ void PipelineExecutor::executeImpl(size_t num_threads, bool concurrency_control)
     SCOPE_EXIT_SAFE(
         if (!finished_flag)
         {
-            finish();
+            /// If finished_flag is not set, there was an exception.
+            /// Cancel execution in this case.
+            cancel();
             if (pool)
                 pool->wait();
         }