fix old owner

pingcap · Aug 15, 2021 · ef9b9ee · ef9b9ee
1 parent 544ed33
commit ef9b9ee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/server.go b/cdc/server.go
@@ -223,7 +223,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