Merge pull request #494 from andyzhangx/storage-endpoint-on-prem

fix: storageEndpointSuffix issue in on-prem cluster

Author: andyzhangx

pkg/blob/azure.go

@@ -25,6 +25,7 @@ import (
 
 	kv "github.com/Azure/azure-sdk-for-go/services/keyvault/2016-10-01/keyvault"
 	"github.com/Azure/azure-sdk-for-go/services/network/mgmt/2021-02-01/network"
+	"github.com/Azure/azure-sdk-for-go/storage"
 
 	"github.com/Azure/go-autorest/autorest"
 
@@ -98,6 +99,9 @@ func getCloudProvider(kubeconfig, nodeID, secretName, secretNamespace, userAgent
 
 	if err != nil {
 		klog.V(2).Infof("no cloud config provided, error: %v, driver will run without cloud config", err)
+		if az.Environment.StorageEndpointSuffix == "" {
+			az.Environment.StorageEndpointSuffix = storage.DefaultBaseURL
+		}
 	}
 
 	isController := (nodeID == "")

pkg/blob/nodeserver.go

@@ -26,6 +26,7 @@ import (
 
 	volumehelper "sigs.k8s.io/blob-csi-driver/pkg/util"
 
+	"github.com/Azure/azure-sdk-for-go/storage"
 	"github.com/container-storage-interface/spec/lib/go/csi"
 
 	"k8s.io/apimachinery/pkg/util/wait"
@@ -238,7 +239,7 @@ func (d *Driver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRe
 		if d.cloud.Environment.StorageEndpointSuffix != "" {
 			storageEndpointSuffix = d.cloud.Environment.StorageEndpointSuffix
 		} else {
-			storageEndpointSuffix = "core.windows.net"
+			storageEndpointSuffix = storage.DefaultBaseURL
 		}
 	}