Fix eventmanager retry interval (#15631)

See also: #15608 Signed-off-by: yangxuan <xuan.yang@zilliz.com>
2022-02-18 17:31:49 +08:00 · 2022-02-18 17:31:49 +08:00 · 23dfbf1f34
parent a1dfcba460
commit 23dfbf1f34
1 changed files with 1 additions and 1 deletions
--- a/internal/datanode/event_manager.go
+++ b/internal/datanode/event_manager.go
@ -60,7 +60,7 @@ func (e *channelEventManager) Run() {
 								zap.String("retry interval", retryWatchInterval.String()),
 								zap.Error(err))

-							<-time.NewTimer(time.Second).C
+							<-time.NewTimer(retryWatchInterval).C

 							select {
 							case e, ok := <-e.eventChan: