Remove useless member of CreatingSetsBlockInputStream (#4535)

close #4536
pingcap · Mar 31, 2022 · 5727db7 · 5727db7
1 parent 7de2666
commit 5727db7
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/dbms/src/DataStreams/CreatingSetsBlockInputStream.h b/dbms/src/DataStreams/CreatingSetsBlockInputStream.h
@@ -41,14 +41,7 @@ class CreatingSetsBlockInputStream : public IProfilingBlockInputStream
         const SizeLimits & network_transfer_limits,
         const String & req_id);
 
-    ~CreatingSetsBlockInputStream()
-    {
-        for (auto & worker : workers)
-        {
-            if (worker.joinable())
-                worker.join();
-        }
-    }
+    ~CreatingSetsBlockInputStream() = default;
 
     static constexpr auto name = "CreatingSets";
 
@@ -101,7 +94,6 @@ class CreatingSetsBlockInputStream : public IProfilingBlockInputStream
     size_t rows_to_transfer = 0;
     size_t bytes_to_transfer = 0;
 
-    std::vector<std::thread> workers;
     std::mutex exception_mutex;
     std::vector<std::exception_ptr> exception_from_workers;