diff --git a/weed/topology/data_node_ec.go b/weed/topology/data_node_ec.go
index cd4c5cd8b..df1b6d658 100644
--- a/weed/topology/data_node_ec.go
+++ b/weed/topology/data_node_ec.go
@@ -62,7 +62,7 @@ func (dn *DataNode) UpdateEcShards(actualShards []*erasure_coding.EcVolumeInfo)
 		deltaDiskUsages := newDiskUsages()
 		deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.ToDiskType(ecShards.DiskType))
 
-		if dn.hasEcShards(ecShards.VolumeId) {
+		if !dn.hasEcShards(ecShards.VolumeId) {
 			newShards = append(newShards, ecShards)
 			newShardCount += ecShards.ShardIdCount()
 		}