Skip to content

Commit

Permalink
resolv conflict
Browse files Browse the repository at this point in the history
Signed-off-by: bufferflies <1045931706@qq.com>
  • Loading branch information
bufferflies committed Oct 12, 2021
1 parent 91ea2b7 commit 6db04e8
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions server/cluster/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -775,16 +775,12 @@ func (s *scheduleController) Stop() {

func (s *scheduleController) Schedule() []*operator.Operator {
for i := 0; i < maxScheduleRetries; i++ {
<<<<<<< HEAD
=======
// no need to retry if schedule should stop to speed exit
select {
case <-s.ctx.Done():
return nil
default:
}
cacheCluster := opt.NewCacheCluster(s.cluster)
>>>>>>> 49ba6b161 (cluster: speed scheduler exit (#4148))
// If we have schedule, reset interval to the minimal interval.
if op := s.Scheduler.Schedule(s.cluster); op != nil {
s.nextInterval = s.Scheduler.GetMinInterval()
Expand Down

0 comments on commit 6db04e8

Please sign in to comment.