diff --git a/hrp/pkg/boomer/runner.go b/hrp/pkg/boomer/runner.go index d9e5d5f4..171e9313 100644 --- a/hrp/pkg/boomer/runner.go +++ b/hrp/pkg/boomer/runner.go @@ -670,8 +670,8 @@ func (r *localRunner) start() { close(r.controller.rebalance) r.wgMu.Unlock() - // wait for goroutines before closing - r.wg.Wait() + //// wait for goroutines before closing + //r.wg.Wait() close(r.doneChan)