Merge pull request ClickHouse#77573 from azat/stateless-distributed

azat · web-flow · commit 5ad8422bf43c · 2025-03-14T06:31:08.000Z
Make Distributed storage stateless compatible
diff --git a/src/Storages/StorageDistributed.cpp b/src/Storages/StorageDistributed.cpp
@@ -951,7 +951,7 @@ SinkToStoragePtr StorageDistributed::write(const ASTPtr &, const StorageMetadata
     }
 
     /// Force sync insertion if it is remote() table function
-    bool insert_sync = settings[Setting::distributed_foreground_insert] || settings[Setting::insert_shard_id] || owned_cluster;
+    bool insert_sync = settings[Setting::distributed_foreground_insert] || settings[Setting::insert_shard_id] || owned_cluster || relative_data_path.empty();
     auto timeout = settings[Setting::distributed_background_insert_timeout];
 
     Names columns_to_send;

Original file line number	Diff line number	Diff line change
`@@ -951,7 +951,7 @@ SinkToStoragePtr StorageDistributed::write(const ASTPtr &, const StorageMetadata`
`951`	`951`	`}`
`952`	`952`
`953`	`953`	`/// Force sync insertion if it is remote() table function`
`954`		`- bool insert_sync = settings[Setting::distributed_foreground_insert] \|\| settings[Setting::insert_shard_id] \|\| owned_cluster;`
	`954`	`+ bool insert_sync = settings[Setting::distributed_foreground_insert] \|\| settings[Setting::insert_shard_id] \|\| owned_cluster \|\| relative_data_path.empty();`
`955`	`955`	`auto timeout = settings[Setting::distributed_background_insert_timeout];`
`956`	`956`
`957`	`957`	`Names columns_to_send;`