fix error

asddongmen · Nov 15, 2023 · 495fff0 · 495fff0
1 parent dd2265b
commit 495fff0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cdc/api/v2/changefeed.go b/cdc/api/v2/changefeed.go
@@ -600,18 +600,20 @@ func (h *OpenAPIV2) resumeChangefeed(c *gin.Context) {
 			_ = c.Error(err)
 			return
 		}
+		// use the default pdClient
 		pdClient = up.PDClient
 	} else {
 		credential := cfg.PDConfig.toCredential()
 		timeoutCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
 		defer cancel()
+		// create a new pdClient
 		pdClient, err = h.helpers.getPDClient(timeoutCtx, cfg.PDAddrs, credential)
 		if err != nil {
 			_ = c.Error(cerror.WrapError(cerror.ErrAPIInvalidParam, err))
 			return
 		}
+		defer pdClient.Close()
 	}
-	defer pdClient.Close()
 
 	if err := h.helpers.verifyResumeChangefeedConfig(
 		ctx,