Skip to content

Commit 17896b3

Browse files
committed
fix TestIntegrationEmbedded
1 parent 6a4b72a commit 17896b3

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

pkg/clickhouse/clickhouse.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,11 @@ func (ch *ClickHouse) getDisksFromSystemDisks(ctx context.Context) ([]Disk, erro
279279
joinStoragePoliciesSQL := ""
280280
if len(diskFields) > 0 && diskFields[0].StoragePolicyPresent > 0 {
281281
storagePoliciesSQL = "groupUniqArray(s.policy_name)"
282-
joinStoragePoliciesSQL = " INNER JOIN (SELECT policy_name, arrayJoin(disks) AS disk FROM system.storage_policies) AS s ON s.disk = d.name"
282+
joinStoragePoliciesSQL = " INNER JOIN "
283+
if ch.Config.UseEmbeddedBackupRestore {
284+
joinStoragePoliciesSQL = " LEFT JOIN "
285+
}
286+
joinStoragePoliciesSQL += "(SELECT policy_name, arrayJoin(disks) AS disk FROM system.storage_policies) AS s ON s.disk = d.name"
283287
}
284288
var result []Disk
285289
query := fmt.Sprintf(

0 commit comments

Comments
 (0)