Merge pull request ClickHouse#72190 from filimonov/patch-12

nickitat · Enmk · commit 1081559056cc · 2025-02-14T08:54:14.000Z
Respect `prefer_locahost_replica` in `parallel_distributed_insert_select`
diff --git a/src/Storages/StorageDistributed.cpp b/src/Storages/StorageDistributed.cpp
@@ -925,7 +925,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);

Original file line number	Diff line number	Diff line change
`@@ -925,7 +925,7 @@ std::optional<QueryPipeline> StorageDistributed::distributedWriteBetweenDistribu`
`925`	`925`	`for (size_t shard_index : collections::range(0, shards_info.size()))`
`926`	`926`	`{`
`927`	`927`	`const auto & shard_info = shards_info[shard_index];`
`928`		`- if (shard_info.isLocal())`
	`928`	`+ if (shard_info.isLocal() && settings.prefer_localhost_replica)`
`929`	`929`	`{`
`930`	`930`	`InterpreterInsertQuery interpreter(new_query, query_context);`
`931`	`931`	`pipeline.addCompletedPipeline(interpreter.execute().pipeline);`