Skip to content

Commit

Permalink
owner: fix owner tick block http api
Browse files Browse the repository at this point in the history
  • Loading branch information
asddongmen committed Nov 17, 2021
1 parent dbd0473 commit 7740829
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cdc/owner/owner.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,12 +118,13 @@ func (o *Owner) Tick(stdCtx context.Context, rawState orchestrator.ReactorState)
state := rawState.(*orchestrator.GlobalReactorState)
o.captures = state.Captures
o.updateMetrics(state)
o.handleJobs()

if !o.clusterVersionConsistent(state.Captures) {
// sleep one second to avoid printing too much log
time.Sleep(1 * time.Second)
return state, nil
}

// Owner should update GC safepoint before initializing changefeed, so
// changefeed can remove its "ticdc-creating" service GC safepoint during
// initializing.
Expand All @@ -133,7 +134,6 @@ func (o *Owner) Tick(stdCtx context.Context, rawState orchestrator.ReactorState)
return nil, errors.Trace(err)
}

o.handleJobs()
for changefeedID, changefeedState := range state.Changefeeds {
if changefeedState.Info == nil {
o.cleanUpChangefeed(changefeedState)
Expand Down

0 comments on commit 7740829

Please sign in to comment.