Merge pull request #598 from Altinity/backports/22.8.21/72190_paralle…

…l_distributed_insert_select

22.8 Backport 72190 respect prefer_locahost_replica=0 in parallel_distributed_insert_select to 22.8

src/Storages/StorageDistributed.cpp

@@ -838,7 +838,7 @@ std::optional<QueryPipeline> StorageDistributed::distributedWriteBetweenDistribu
     for (size_t shard_index : collections::range(0, shards_info.size()))
     {
         const auto & shard_info = shards_info[shard_index];
-        if (shard_info.isLocal())
+        if (shard_info.isLocal() && settings.prefer_localhost_replica)
         {
             InterpreterInsertQuery interpreter(new_query, query_context);
             pipeline.addCompletedPipeline(interpreter.execute().pipeline);