fix(controller): unmap volume from given node id instead of all nodes

Seagate · Mar 4, 2020 · 51e719e · 51e719e
1 parent d37fafc
commit 51e719e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/controller/attacher.go b/pkg/controller/attacher.go
@@ -72,8 +72,8 @@ func (driver *Driver) ControllerUnpublishVolume(ctx context.Context, req *csi.Co
 		return nil, err
 	}
 
-	klog.Infof("unmapping volume %s from all initiators", req.GetVolumeId())
-	_, status, err := driver.dothillClient.UnmapVolume(req.GetVolumeId(), "")
+	klog.Infof("unmapping volume %s from initiator %s", req.GetVolumeId(), req.GetNodeId())
+	_, status, err := driver.dothillClient.UnmapVolume(req.GetVolumeId(), req.GetNodeId())
 	if err != nil {
 		if status != nil && status.ReturnCode == unmapFailedErrorCode {
 			klog.Info("unmap failed, assuming volume is already unmapped")