Skip to content

Commit

Permalink
fix conflicts
Browse files Browse the repository at this point in the history
Signed-off-by: qupeng <[email protected]>
  • Loading branch information
hicqu committed Dec 17, 2023
1 parent b0a608d commit 7dab125
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions cdc/processor/sinkmanager/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -188,7 +188,6 @@ func New(
}

m.ready = make(chan struct{})
<<<<<<< HEAD
m.wg.Add(1) // So `SinkManager.Close` will also wait the subroutine.
go func() {
if err := m.run(ctx, warnChan); err != nil && errors.Cause(err) != context.Canceled {
Expand All @@ -200,9 +199,6 @@ func New(
}()
<-m.ready
return m, nil
=======
return m
>>>>>>> 844b41bed4 (redo(cdc): custom redo event cache and disable it by default (#10139))
}

func (m *SinkManager) run(ctx context.Context, warnings ...chan<- error) (err error) {
Expand Down

0 comments on commit 7dab125

Please sign in to comment.