diff --git a/pkg/volume/awsebs/aws_util.go b/pkg/volume/awsebs/aws_util.go index 4a3ae61e955..e5f8e7fc613 100644 --- a/pkg/volume/awsebs/aws_util.go +++ b/pkg/volume/awsebs/aws_util.go @@ -41,8 +41,9 @@ import ( ) const ( - diskPartitionSuffix = "" - checkSleepDuration = time.Second + diskPartitionSuffix = "" + nvmeDiskPartitionSuffix = "p" + checkSleepDuration = time.Second ) // AWSDiskUtil provides operations for EBS volume. @@ -240,6 +241,9 @@ func getDiskByIDPaths(volumeID aws.KubernetesVolumeID, partition string, deviceP if err != nil { klog.Warningf("error looking for nvme volume %q: %v", volumeID, err) } else if nvmePath != "" { + if partition != "" { + nvmePath = nvmePath + nvmeDiskPartitionSuffix + partition + } devicePaths = append(devicePaths, nvmePath) } }