diff --git a/internal/controllers/sync-volume/utils.go b/internal/controllers/sync-volume/utils.go
index 8219d3f6..153ec92f 100644
--- a/internal/controllers/sync-volume/utils.go
+++ b/internal/controllers/sync-volume/utils.go
@@ -29,6 +29,7 @@ import (
 	"fmt"
 	"math"
 	"strconv"
+	"strings"
 
 	"github.com/go-logr/logr"
 	"github.com/pkg/errors"
@@ -78,7 +79,17 @@ func getConverter(vol *stosv1.Volume, obj storageos.Object, log logr.Logger) fun
 		if vol.ObjectMeta.Labels == nil {
 			vol.ObjectMeta.Labels = make(map[string]string)
 		}
-		vol.ObjectMeta.Labels["master-node-id"] = stosVol.Master.NodeID
+		for k := range vol.ObjectMeta.Labels {
+			if strings.HasPrefix(k, "storageos-node-") {
+				delete(vol.ObjectMeta.Labels, k)
+			}
+		}
+		vol.ObjectMeta.Labels[fmt.Sprintf("storageos-node-%s", stosVol.Master.NodeID)] = "master"
+		if stosVol.Replicas != nil {
+			for _, replica := range *stosVol.Replicas {
+				vol.ObjectMeta.Labels[fmt.Sprintf("storageos-node-%s", replica.NodeID)] = "replica"
+			}
+		}
 
 		sizeBytes, err := convertUint64ToInt64(stosVol.SizeBytes)
 		if err != nil {