plugin: add lost rewatch sleep in plugin loop (pingcap#49292)

ref pingcap#49273
dveeden · Dec 8, 2023 · 899dfe8 · 899dfe8
1 parent d23e1c3
commit 899dfe8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/plugin/plugin.go b/pkg/plugin/plugin.go
@@ -289,6 +289,7 @@ func (w *flushWatcher) watchLoop() {
  "plugin flushWatcher old chan closed, restart loop later",
  zap.String("plugin", w.manifest.Name),
  zap.Duration("after", reWatchInterval))
+ time.Sleep(reWatchInterval)
  }
 }