disk: refine create volume error code

Avoid unknown code.
Use InvalidArgument for anything needs user adjusting.

Author: huww98

pkg/disk/cloud.go

@@ -984,11 +984,11 @@ func createDisk(ecsClient cloud.ECSInterface, diskName, snapshotID string, diskV
 			if errors.Is(err, ErrParameterMismatch) {
 				if createDiskRequest.ClientToken == "" {
 					// protect us from infinite loop
-					return "", attempt, fmt.Errorf("unexpected parameter mismatch")
+					return "", attempt, status.Error(codes.Internal, "unexpected parameter mismatch")
 				}
 				existingDisk, err := findDiskByName(diskName, ecsClient)
 				if err != nil {
-					return "", attempt, fmt.Errorf("parameter mismatch detected, but fetch existing node failed: %w", err)
+					return "", attempt, status.Errorf(codes.Internal, "parameter mismatch detected, but fetch existing disk failed: %v", err)
 				}
 				if existingDisk == nil {
 					// No existing disk, retry without client token
@@ -1007,7 +1007,7 @@ func createDisk(ecsClient cloud.ECSInterface, diskName, snapshotID string, diskV
 		}
 		return diskID, attempt, nil
 	}
-	return "", createAttempt{}, status.Errorf(codes.Internal, "all attempts failed: %s", strings.Join(messages, "; "))
+	return "", createAttempt{}, status.Errorf(codes.InvalidArgument, "all attempts failed: %s", strings.Join(messages, "; "))
 }
 
 func buildCreateDiskRequest(diskVol *diskVolumeArgs) *ecs.CreateDiskRequest {

pkg/disk/controllerserver.go

@@ -200,6 +200,8 @@ func (cs *controllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
 			switch aliErr.ErrorCode() {
 			case SnapshotNotFound:
 				return nil, status.Errorf(codes.NotFound, "snapshot %s not found", snapshotID)
+			default:
+				return nil, status.Error(codes.Internal, err.Error())
 			}
 		}
 		return nil, err