fix call get capture by id, pass target capture id instead of the add…

…ress.
pingcap · Oct 18, 2022 · 433accc · 433accc
1 parent 4675eba
commit 433accc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/cluster/api/cdcapi.go b/pkg/cluster/api/cdcapi.go
@@ -110,7 +110,7 @@ func drainCapture(client *CDCOpenAPIClient, target string) (int, error) {
 
 // DrainCapture request cdc owner move all tables on the target capture to other captures.
 func (c *CDCOpenAPIClient) DrainCapture(addr, target string, apiTimeoutSeconds int) error {
-	if _, err := c.getCaptureByID(addr); err != nil {
+	if _, err := c.getCaptureByID(target); err != nil {
 		c.l().Debugf("cdc drain capture failed, cannot find the capture, address: %s, target: %s, err: %+v", addr, target, err)
 		return err
 	}