diff --git a/pkg/csi/fuse/nodeserver.go b/pkg/csi/fuse/nodeserver.go index 69d04a01c52..8b7a777dfd6 100644 --- a/pkg/csi/fuse/nodeserver.go +++ b/pkg/csi/fuse/nodeserver.go @@ -283,15 +283,6 @@ func (ns *nodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol glog.Info("NodeStageVolume: label already exists on node", "label", fuseLabelKey, "node", node) } - fluidPath := req.GetVolumeContext()["fluid_path"] - mountType := req.GetVolumeContext()["mount_type"] - - // checkMountReady checks the fuse mount path every 3 second for 30 seconds in total. - err = utils.CheckMountReady(fluidPath, mountType) - if err != nil { - return nil, errors.Errorf("fuse pod on node %s is not ready", ns.nodeId) - } - return &csi.NodeStageVolumeResponse{}, nil }