From 17896b31fe9a38e5b7cc4589926973b33b91aaa0 Mon Sep 17 00:00:00 2001 From: Slach Date: Mon, 5 Feb 2024 15:39:42 +0400 Subject: [PATCH] fix TestIntegrationEmbedded --- pkg/clickhouse/clickhouse.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/clickhouse/clickhouse.go b/pkg/clickhouse/clickhouse.go index 73c9c35b..025adc2e 100644 --- a/pkg/clickhouse/clickhouse.go +++ b/pkg/clickhouse/clickhouse.go @@ -279,7 +279,11 @@ func (ch *ClickHouse) getDisksFromSystemDisks(ctx context.Context) ([]Disk, erro joinStoragePoliciesSQL := "" if len(diskFields) > 0 && diskFields[0].StoragePolicyPresent > 0 { storagePoliciesSQL = "groupUniqArray(s.policy_name)" - joinStoragePoliciesSQL = " INNER JOIN (SELECT policy_name, arrayJoin(disks) AS disk FROM system.storage_policies) AS s ON s.disk = d.name" + joinStoragePoliciesSQL = " INNER JOIN " + if ch.Config.UseEmbeddedBackupRestore { + joinStoragePoliciesSQL = " LEFT JOIN " + } + joinStoragePoliciesSQL += "(SELECT policy_name, arrayJoin(disks) AS disk FROM system.storage_policies) AS s ON s.disk = d.name" } var result []Disk query := fmt.Sprintf(