Skip to content

Commit

Permalink
This is an automated cherry-pick of pingcap#9953
Browse files Browse the repository at this point in the history
Signed-off-by: ti-chi-bot <[email protected]>
  • Loading branch information
CharlesCheung96 authored and ti-chi-bot committed Oct 26, 2023
1 parent 6ba0aec commit dc008bb
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions cdc/owner/changefeed.go
Original file line number Diff line number Diff line change
Expand Up @@ -447,12 +447,20 @@ LOOP2:
}
}

<<<<<<< HEAD
checkpointTs := c.state.Status.CheckpointTs
if c.resolvedTs == 0 {
c.resolvedTs = checkpointTs
}

minTableBarrierTs := c.state.Status.MinTableBarrierTs
=======
checkpointTs := c.latestStatus.CheckpointTs
if c.resolvedTs == 0 {
c.resolvedTs = checkpointTs
}
minTableBarrierTs := c.latestStatus.MinTableBarrierTs
>>>>>>> 0c29040814 (scheduler(ticdc): revert 3b8d55 and do not return error when resolvedTs less than checkpoint (#9953))

failpoint.Inject("NewChangefeedNoRetryError", func() {
failpoint.Return(cerror.ErrStartTsBeforeGC.GenWithStackByArgs(checkpointTs-300, checkpointTs))
Expand Down

0 comments on commit dc008bb

Please sign in to comment.