diff --git a/pkg/cluster/k8sres.go b/pkg/cluster/k8sres.go index 8d0d16df29ac9b70f82ec6eac48cc3135aa326c2..cf84f420bcc66f88bbe1df7a74cbdb094150ff29 100644 --- a/pkg/cluster/k8sres.go +++ b/pkg/cluster/k8sres.go @@ -1867,22 +1867,15 @@ func (c *Cluster) generateCloneEnvironment(description *acidv1.CloneDescription) } else { c.logger.Debugf("use S3WalPath %s from the manifest", description.S3WalPath) - envs := []v1.EnvVar{ - { - Name: "CLONE_WALE_S3_PREFIX", - Value: description.S3WalPath, - }, - { - Name: "CLONE_WAL_BUCKET_SCOPE_SUFFIX", - Value: "", - }, - } - - result = append(result, envs...) + result = append(result, v1.EnvVar{ + Name: "CLONE_WALE_S3_PREFIX", + Value: description.S3WalPath, + }) } result = append(result, v1.EnvVar{Name: "CLONE_METHOD", Value: "CLONE_WITH_WALE"}) result = append(result, v1.EnvVar{Name: "CLONE_TARGET_TIME", Value: description.EndTimestamp}) + result = append(result, v1.EnvVar{Name: "CLONE_WAL_BUCKET_SCOPE_PREFIX", Value: ""}) if description.S3Endpoint != "" { result = append(result, v1.EnvVar{Name: "CLONE_AWS_ENDPOINT", Value: description.S3Endpoint}) diff --git a/pkg/cluster/k8sres_test.go b/pkg/cluster/k8sres_test.go index d966344e4e22b62d3c73c25372b0bf4f6ee2eb6d..7f96a223456f11fb068f5d65360b0c08edf6086c 100644 --- a/pkg/cluster/k8sres_test.go +++ b/pkg/cluster/k8sres_test.go @@ -550,8 +550,8 @@ func TestGenerateSpiloPodEnvVars(t *testing.T) { envVarValue: "s3://another-bucket", }, { - envIndex: 17, - envVarConstant: "CLONE_WAL_BUCKET_SCOPE_SUFFIX", + envIndex: 19, + envVarConstant: "CLONE_WAL_BUCKET_SCOPE_PREFIX", envVarValue: "", }, { @@ -572,14 +572,14 @@ func TestGenerateSpiloPodEnvVars(t *testing.T) { envVarValue: fmt.Sprintf("/%s", dummyUUID), }, { - envIndex: 20, + envIndex: 21, envVarConstant: "clone_aws_endpoint", envVarValue: "s3.eu-west-1.amazonaws.com", }, } expectedCloneEnvSecret := []ExpectedValue{ { - envIndex: 20, + envIndex: 21, envVarConstant: "clone_aws_access_key_id", envVarValueRef: &v1.EnvVarSource{ SecretKeyRef: &v1.SecretKeySelector{