From 1e1b23035d831f55e7013282191a7b283f907a2b Mon Sep 17 00:00:00 2001 From: amyangfei Date: Sun, 15 Aug 2021 20:19:59 +0800 Subject: [PATCH] fix old owner --- cdc/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cdc/server.go b/cdc/server.go index 050737f23c9..779c211364a 100644 --- a/cdc/server.go +++ b/cdc/server.go @@ -224,7 +224,7 @@ func (s *Server) campaignOwnerLoop(ctx context.Context) error { } captureID := s.capture.info.ID log.Info("campaign owner successfully", zap.String("capture-id", captureID)) - owner, err := NewOwner(ctx, s.pdClient, conf.Security, s.capture.session, conf.GcTTL, time.Duration(conf.OwnerFlushInterval)) + owner, err := NewOwner(ctx, s.pdClient, s.capture.grpcPool, s.capture.session, conf.GcTTL, time.Duration(conf.OwnerFlushInterval)) if err != nil { log.Warn("create new owner failed", zap.Error(err)) continue