Merge pull request #648 from Altinity/features/fix_parallel_loading_i…

…n_distributed_requests

Limit parsing threads for distibuted case

src/Storages/ObjectStorage/StorageObjectStorage.cpp

@@ -244,7 +244,7 @@ class ReadFromObjectStorageStep : public SourceStepWithFilter
             num_streams = 1;
         }
 
-        const size_t max_parsing_threads = num_streams >= max_threads ? 1 : (max_threads / std::max(num_streams, 1ul));
+        const size_t max_parsing_threads = (distributed_processing || num_streams >= max_threads) ? 1 : (max_threads / std::max(num_streams, 1ul));
 
         for (size_t i = 0; i < num_streams; ++i)
         {