diff --git a/pkg/common/stopper/stopper.go b/pkg/common/stopper/stopper.go index 5ec7799ac16815aa8b709df152bc68cb57a815f9..f2d6bd3148be7b40a272b678c90691d20b680f3b 100644 --- a/pkg/common/stopper/stopper.go +++ b/pkg/common/stopper/stopper.go @@ -245,9 +245,6 @@ func (s *Stopper) shutdownTask(id uint64) { func (s *Stopper) doRunCancelableTask(ctx context.Context, taskID uint64, name string, task func(context.Context)) { s.setupTask(taskID, name) go func() { - if err := recover(); err != nil { - panic(err) - } defer func() { s.shutdownTask(taskID) }()