diff --git a/pkg/cluster/api/binlog.go b/pkg/cluster/api/binlog.go
index c92efc65c3..e8d4c9406a 100644
--- 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) {