Stop query execution if exception happened in PipelineExecutor itself.

src/Processors/Executors/PipelineExecutor.cpp

@@ -468,8 +468,17 @@ void PipelineExecutor::wakeUpExecutor(size_t thread_num)
 }
 
 void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads)
+{
+    try
     {
         executeStepImpl(thread_num, num_threads);
+    }
+    catch (...)
+    {
+        /// In case of exception from executor itself, stop other threads.
+        finish();
+        throw;
+    }
 
 #ifndef NDEBUG
     auto & context = executor_contexts[thread_num];