diff --git a/internal/cephfs/controllerserver.go b/internal/cephfs/controllerserver.go
index 8e72082da..d62ca53de 100644
--- a/internal/cephfs/controllerserver.go
+++ b/internal/cephfs/controllerserver.go
@@ -86,7 +86,7 @@ func (cs *ControllerServer) createBackingVolume(
 		return nil
 	}
 
-	if err = createVolume(ctx, volOptions, cr, volumeID(vID.FsSubvolName), volOptions.Size); err != nil {
+	if err = createVolume(ctx, volOptions, volumeID(vID.FsSubvolName), volOptions.Size); err != nil {
 		util.ErrorLog(ctx, "failed to create volume %s: %v", volOptions.RequestName, err)
 		return status.Error(codes.Internal, err.Error())
 	}
diff --git a/internal/cephfs/volume.go b/internal/cephfs/volume.go
index 4ddacd6b5..1cef25528 100644
--- a/internal/cephfs/volume.go
+++ b/internal/cephfs/volume.go
@@ -130,7 +130,7 @@ type localClusterState struct {
 	subVolumeGroupCreated bool
 }
 
-func createVolume(ctx context.Context, volOptions *volumeOptions, cr *util.Credentials, volID volumeID, bytesQuota int64) error {
+func createVolume(ctx context.Context, volOptions *volumeOptions, volID volumeID, bytesQuota int64) error {
 	// verify if corresponding ClusterID key is present in the map,
 	// and if not, initialize with default values(false).
 	if _, keyPresent := clusterAdditionalInfo[volOptions.ClusterID]; !keyPresent {
@@ -218,7 +218,7 @@ func resizeVolume(ctx context.Context, volOptions *volumeOptions, cr *util.Crede
 		}
 	}
 	clusterAdditionalInfo[volOptions.ClusterID].resizeSupported = false
-	return createVolume(ctx, volOptions, cr, volID, bytesQuota)
+	return createVolume(ctx, volOptions, volID, bytesQuota)
 }
 
 func purgeVolume(ctx context.Context, volID volumeID, cr *util.Credentials, volOptions *volumeOptions, force bool) error {