Skip to content

Commit

Permalink
Update cdc/processor/processor.go
Browse files Browse the repository at this point in the history
Co-authored-by: CharlesCheung <[email protected]>
  • Loading branch information
sdojjy and CharlesCheung96 authored Sep 21, 2023
1 parent fe769e0 commit 745a0c0
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion cdc/processor/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -470,7 +470,8 @@ func isProcessorIgnorableError(err error) bool {
// maintain table components, error handling, etc.
//
// It can be called in etcd ticks, so it should never be blocked.
func (p *processor) Tick(ctx cdcContext.Context,
func (p *processor) Tick(
ctx cdcContext.Context,
info *model.ChangeFeedInfo, status *model.ChangeFeedStatus,
) (error, error) {
p.latestInfo = info
Expand Down

0 comments on commit 745a0c0

Please sign in to comment.