diff --git a/master/flash_group.go b/master/flash_group.go index 07f25facc..590f95a02 100644 --- a/master/flash_group.go +++ b/master/flash_group.go @@ -482,6 +482,7 @@ func (c *Cluster) setFlashNodeToUnused(addr string, flashGroupID uint64) (flashN } go func() { + time.Sleep(65 * time.Second) arr := strings.SplitN(addr, ":", 2) p, _ := strconv.ParseUint(arr[1], 10, 64) addr = fmt.Sprintf("%s:%d", arr[0], p+1) diff --git a/master/flash_node.go b/master/flash_node.go index a65e5ed55..ffc94dad5 100644 --- a/master/flash_node.go +++ b/master/flash_node.go @@ -322,6 +322,7 @@ func (c *Cluster) removeFlashNode(flashNode *FlashNode) (err error) { } go func() { + time.Sleep(65 * time.Second) arr := strings.SplitN(flashNode.Addr, ":", 2) p, _ := strconv.ParseUint(arr[1], 10, 64) addr := fmt.Sprintf("%s:%d", arr[0], p+1)