fix pd caller

Signed-off-by: xhe <xw897002528@gmail.com>

cdc/api/v2/api_helpers.go

@@ -458,7 +458,7 @@ func (APIV2HelpersImpl) getPDClient(
 	}
 
 	pdClient, err := pd.NewClientWithContext(
-		ctx, "tiflow", pdAddrs, credential.PDSecurityOption(),
+		ctx, "", pdAddrs, credential.PDSecurityOption(),
 		pdopt.WithGRPCDialOptions(
 			grpcTLSOption,
 			grpc.WithBlock(),

cdc/server/server.go

@@ -135,7 +135,7 @@ func (s *server) prepare(ctx context.Context) error {
 	}
 	log.Info("create pd client", zap.Strings("endpoints", s.pdEndpoints))
 	s.pdClient, err = pd.NewClientWithContext(
-		ctx, "tiflow", s.pdEndpoints, conf.Security.PDSecurityOption(),
+		ctx, "", s.pdEndpoints, conf.Security.PDSecurityOption(),
 		// the default `timeout` is 3s, maybe too small if the pd is busy,
 		// set to 10s to avoid frequent timeout.
 		pdopt.WithCustomTimeoutOption(10*time.Second),

pkg/cmd/factory/factory_impl.go

@@ -138,7 +138,7 @@ func (f *factoryImpl) PdClient() (pd.Client, error) {
 	}
 
 	pdClient, err := pd.NewClientWithContext(
-		ctx, "tiflow", pdEndpoints, credential.PDSecurityOption(),
+		ctx, "", pdEndpoints, credential.PDSecurityOption(),
 		pdopt.WithMaxErrorRetry(maxGetPDClientRetryTimes),
 		// TODO(hi-rustin): add gRPC metrics to Options.
 		// See also: https://github.com/pingcap/tiflow/pull/2341#discussion_r673032407.

pkg/migrate/migrate.go

@@ -135,7 +135,7 @@ func createPDClient(ctx context.Context,
 		return nil, errors.Trace(err)
 	}
 	return pd.NewClientWithContext(
-		ctx, "tiflow", pdEndpoints, conf.PDSecurityOption(),
+		ctx, "", pdEndpoints, conf.PDSecurityOption(),
 		pdopt.WithGRPCDialOptions(
 			grpcTLSOption,
 			grpc.WithBlock(),

pkg/upstream/upstream.go

@@ -137,7 +137,7 @@ func initUpstream(ctx context.Context, up *Upstream, cfg CaptureTopologyCfg) err
 	// default upstream always use the pdClient pass from cdc server
 	if !up.isDefaultUpstream {
 		up.PDClient, err = pd.NewClientWithContext(
-			ctx, "tiflow", up.PdEndpoints, up.SecurityConfig.PDSecurityOption(),
+			ctx, "", up.PdEndpoints, up.SecurityConfig.PDSecurityOption(),
 			// the default `timeout` is 3s, maybe too small if the pd is busy,
 			// set to 10s to avoid frequent timeout.
 			pdopt.WithCustomTimeoutOption(10*time.Second),

sync_diff_inspector/utils/pd.go

@@ -115,7 +115,7 @@ func GetPDClientForGC(ctx context.Context, db *sql.DB) (pd.Client, error) {
 			if same, err := checkSameCluster(ctx, db, pdAddrs); err != nil {
 				log.Info("[automatically GC] check whether fetched pd addr and TiDB belong to one cluster failed", zap.Strings("pd address", pdAddrs), zap.Error(err))
 			} else if same {
-				pdClient, err := pd.NewClientWithContext(ctx, "tiflow", pdAddrs, pd.SecurityOption{})
+				pdClient, err := pd.NewClientWithContext(ctx, "", pdAddrs, pd.SecurityOption{})
 				if err != nil {
 					log.Info("[automatically GC] create pd client to control GC failed", zap.Strings("pd address", pdAddrs), zap.Error(err))
 					return nil, err