fix: fix can not get drainer status from pd (#1922)

pingcap · Jun 16, 2022 · 00a67b8 · 00a67b8
1 parent e52c3bb
commit 00a67b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/cluster/api/binlog.go b/pkg/cluster/api/binlog.go
@@ -100,7 +100,7 @@ func (c *BinlogClient) IsDrainerTombstone(ctx context.Context, addr string) (boo
 	if err != nil {
 		return false, err
 	}
-	return c.isTombstone(ctx, "drainer", nodeID)
+	return c.isTombstone(ctx, "drainers", nodeID)
 }
 
 func (c *BinlogClient) isTombstone(ctx context.Context, ty string, nodeID string) (bool, error) {