fix

Author: umagnus

pkg/blob/controllerserver.go

@@ -763,7 +763,7 @@ func (d *Driver) copyBlobContainer(ctx context.Context, req *csi.CreateVolumeReq
 		sourceVolumeID = req.GetVolumeContentSource().GetVolume().GetVolumeId()
 
 	}
-	resourceGroupName, srcAccountName, srcContainerName, _, _, err := GetContainerInfo(sourceVolumeID) //nolint:dogsled
+	srcResourceGroupName, srcAccountName, srcContainerName, _, srcSubscriptionID, err := GetContainerInfo(sourceVolumeID) //nolint:dogsled
 	if err != nil {
 		return status.Error(codes.NotFound, err.Error())
 	}
@@ -777,8 +777,8 @@ func (d *Driver) copyBlobContainer(ctx context.Context, req *csi.CreateVolumeReq
 	if srcAccountName != dstAccountName && dstAccountSasToken != "" {
 		srcAccountOptions := &azure.AccountOptions{
 			Name:                srcAccountName,
-			ResourceGroup:       accountOptions.ResourceGroup,
-			SubscriptionID:      accountOptions.SubscriptionID,
+			ResourceGroup:       srcResourceGroupName,
+			SubscriptionID:      srcSubscriptionID,
 			GetLatestAccountKey: accountOptions.GetLatestAccountKey,
 		}
 		if srcAccountSasToken, _, err = d.getAzcopyAuth(ctx, srcAccountName, "", storageEndpointSuffix, srcAccountOptions, nil, "", secretNamespace); err != nil {
@@ -809,7 +809,7 @@ func (d *Driver) copyBlobContainer(ctx context.Context, req *csi.CreateVolumeReq
 		}
 		copyErr := util.WaitUntilTimeout(time.Duration(d.waitForAzCopyTimeoutMinutes)*time.Minute, execFunc, timeoutFunc)
 		if copyErr != nil {
-			klog.Warningf("CopyBlobContainer(%s, %s, %s) failed with error: %v", resourceGroupName, dstAccountName, dstContainerName, copyErr)
+			klog.Warningf("CopyBlobContainer(%s, %s, %s) failed with error: %v", accountOptions.ResourceGroup, dstAccountName, dstContainerName, copyErr)
 		} else {
 			klog.V(2).Infof("copied blob container %s to %s successfully", srcContainerName, dstContainerName)
 		}