Attempting alternative where target is chowned to the correct group

pkg/driver/node.go

@@ -132,12 +132,6 @@ func (d *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolu
 		mountOptions = append(mountOptions, "ro")
 	}
 
-	fsGroup := volCap.GetMount().VolumeMountGroup
-	if fsGroup != "" {
-		klog.V(5).Infof("Adding fsGroup parameter of %s to mount call", fsGroup)
-		mountOptions = append(mountOptions, fmt.Sprintf("gid=%s", fsGroup))
-	}
-
 	if m := volCap.GetMount(); m != nil {
 		for _, f := range m.MountFlags {
 			// Special-case check for access point
@@ -188,6 +182,13 @@ func (d *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolu
 	}
 	klog.V(5).Infof("NodePublishVolume: %s was mounted", target)
 
+	fsGroup := volCap.GetMount().VolumeMountGroup
+	if fsGroup != "" {
+		fsGroupParsed, _ := strconv.ParseInt(fsGroup, 10, 64)
+		klog.V(5).Infof("NodePublishVolume: changing GID of %s to %s", target, fsGroup)
+		os.Chown(target, -1, int(fsGroupParsed))
+	}
+
 	//Increment volume Id counter
 	if d.volMetricsOptIn {
 		if value, ok := volumeIdCounter[req.GetVolumeId()]; ok {

pkg/driver/node_test.go

@@ -353,8 +353,8 @@ func TestNodePublishVolume(t *testing.T) {
 				TargetPath: targetPath,
 			},
 			expectMakeDir: true,
-			mountArgs:     []interface{}{volumeId + ":/", targetPath, "efs", []string{"tls", "gid=1000"}},
 			mountSuccess:  true,
+			mountArgs:     []interface{}{volumeId + ":/", targetPath, "efs", []string{"tls"}},
 		},
 		{
 			name: "fail: conflicting access point in volume handle and mount options",