bugfix: unregister ec shards when volume server disconnected (#5697)

bugfix unregister ec shards when volume server disconnected Co-authored-by: liguowei <liguowei@xinye.com>
6 months ago · 73baf82f05
1 changed files with 5 additions and 0 deletions
--- a/weed/topology/topology_event_handling.go
+++ b/weed/topology/topology_event_handling.go
@ -90,6 +90,11 @@ func (t *Topology) UnRegisterDataNode(dn *DataNode) {
 		vl.SetVolumeUnavailable(dn, v.Id)
 	}

+	// unregister ec shards when volume server disconnected
+	for _, s := range dn.GetEcShards() {
+		t.UnRegisterEcShards(s, dn)
+	}
+
 	negativeUsages := dn.GetDiskUsages().negative()
 	dn.UpAdjustDiskUsageDelta(negativeUsages)
 	dn.DeltaUpdateVolumes([]storage.VolumeInfo{}, dn.GetVolumes())