diff --git a/pkg/volume/portworx/portworx_util.go b/pkg/volume/portworx/portworx_util.go index 6c4cec1b39..a2fee466e1 100644 --- a/pkg/volume/portworx/portworx_util.go +++ b/pkg/volume/portworx/portworx_util.go @@ -72,12 +72,14 @@ func (util *portworxVolumeUtil) CreateVolume(p *portworxVolumeProvisioner) (stri } // Pass all parameters as volume labels for Portworx server-side processing - if len(p.options.Parameters) > 0 { - spec.VolumeLabels = p.options.Parameters - } else { + if spec.VolumeLabels == nil { spec.VolumeLabels = make(map[string]string, 0) } + for k, v := range p.options.Parameters { + spec.VolumeLabels[k] = v + } + // Update the requested size in the spec spec.Size = uint64(requestGiB * volumehelpers.GiB)