Changed cluster function to list of remote hosts.

Author: alex-zaitsev

pkg/model/schemer.go

@@ -83,7 +83,10 @@ func (s *Schemer) getObjectListFromClickHouse(serviceUrl string, sql string) ([]
 // GetCreateDistributedObjects returns a list of objects that needs to be created on a shard in a cluster
 // That includes all Distributed tables, corresponding local tables, and databases, if necessary
 func (s *Schemer) ClusterGetCreateDistributedObjects(chi *chop.ClickHouseInstallation, cluster *chop.ChiCluster) ([]string, []string, error) {
-	system_tables := fmt.Sprintf("cluster('%s', system, tables)", cluster.Name)
+	// system_tables := fmt.Sprintf("cluster('%s', system, tables)", cluster.Name)
+	hosts := CreatePodFQDNsOfCluster(cluster)
+	system_tables := fmt.Sprintf("remote('%s', system, tables)", strings.Join(hosts, ","))
+
 	sql := heredoc.Doc(strings.ReplaceAll(`
 		SELECT DISTINCT 
 			database AS name,