fix old owner

pingcap · Aug 15, 2021 · 1e1b230 · 1e1b230
1 parent f37d3b1
commit 1e1b230
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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