diff --git a/dbms/src/DataStreams/CreatingSetsBlockInputStream.h b/dbms/src/DataStreams/CreatingSetsBlockInputStream.h
index 5f7615b6039..2f9ad61e4c8 100644
--- 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;