diff --git a/pkg/cmd/roachtest/tests/failover.go b/pkg/cmd/roachtest/tests/failover.go index fb03523751b1..cf0c215c0d73 100644 --- a/pkg/cmd/roachtest/tests/failover.go +++ b/pkg/cmd/roachtest/tests/failover.go @@ -1516,9 +1516,9 @@ func (f *deadlockFailer) Fail(ctx context.Context, nodeID int) { ctx, cancel := context.WithTimeout(ctx, 20*time.Second) // can take a while to lock defer cancel() - predicate := `$1 = ANY(replicas)` + predicate := `$1::int = ANY(replicas)` if f.onlyLeaseholders { - predicate += ` AND lease_holder = $1` + predicate += ` AND lease_holder = $1::int` } conn := f.c.Conn(ctx, f.t.L(), nodeID)