Skip to content

Commit

Permalink
fix merge conflict
Browse files Browse the repository at this point in the history
  • Loading branch information
amyangfei committed Aug 15, 2021
1 parent 0187468 commit f37d3b1
Showing 1 changed file with 1 addition and 7 deletions.
8 changes: 1 addition & 7 deletions cdc/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -818,14 +818,8 @@ func (p *oldProcessor) addTable(ctx context.Context, tableID int64, replicaInfo
}
// NOTICE: always pull the old value internally
// See also: TODO(hi-rustin): add issue link here.
<<<<<<< HEAD
plr := puller.NewPuller(ctx, p.pdCli, p.credential, kvStorage,
replicaInfo.StartTs, []regionspan.Span{span}, true)
=======
plr := puller.NewPuller(ctx, p.pdCli, p.grpcPool, kvStorage,
replicaInfo.StartTs, []regionspan.Span{span},
true)
>>>>>>> 4f7c0b96 (kv/client: add global grpc connection pool (#2511))
replicaInfo.StartTs, []regionspan.Span{span}, true)
go func() {
err := plr.Run(ctx)
if errors.Cause(err) != context.Canceled {
Expand Down

0 comments on commit f37d3b1

Please sign in to comment.