diff --git a/scheduler/resource/peer.go b/scheduler/resource/peer.go
index a75440f89..3b566e945 100644
--- a/scheduler/resource/peer.go
+++ b/scheduler/resource/peer.go
@@ -199,6 +199,7 @@ func NewPeer(id string, task *Task, host *Host) *Peer {
 					p.Task.BackToSourcePeers.Delete(p)
 				}
 
+				p.DeleteParent()
 				p.UpdateAt.Store(time.Now())
 				p.Log.Infof("peer state is %s", e.FSM.Current())
 			},