From bb5bfef1077562833b9caac8423f6024968572b7 Mon Sep 17 00:00:00 2001 From: tnextday Date: Fri, 25 Dec 2015 00:52:31 +0800 Subject: [PATCH] StoreTask: send heartbeat when commit the replicat task --- go/storage/store_task_replication.go | 1 + 1 file changed, 1 insertion(+) diff --git a/go/storage/store_task_replication.go b/go/storage/store_task_replication.go index 6cad71ac4..b6b8e230a 100644 --- a/go/storage/store_task_replication.go +++ b/go/storage/store_task_replication.go @@ -89,6 +89,7 @@ func (t *ReplicaTask) Commit() error { volume, e = NewVolume(t.location.Directory, t.Collection, t.VID, t.s.needleMapKind, nil) if e == nil { t.location.volumes[t.VID] = volume + t.s.SendHeartbeatToMaster() } return e }