fix: peer keepalive with manager
@@ -309,7 +309,6 @@ func (a *announcer) announceToManager() error {
}); err != nil {
return err
}
- }
// Start keepalive to manager.
go func() {
@@ -320,6 +319,7 @@ func (a *announcer) announceToManager() error {
ClusterId: uint64(a.config.Scheduler.Manager.SeedPeer.ClusterID),
}, a.done)
}()
+ }
return nil
}
