diff --git a/pkg/sql/ttl/ttljob/ttljob_processor.go b/pkg/sql/ttl/ttljob/ttljob_processor.go index 914120a8ba3b..9e576c0183d3 100644 --- a/pkg/sql/ttl/ttljob/ttljob_processor.go +++ b/pkg/sql/ttl/ttljob/ttljob_processor.go @@ -143,7 +143,7 @@ func (t *ttlProcessor) work(ctx context.Context) error { return errors.Wrapf(err, "error fetching table relation name for TTL") } - relationName = tn.FQString() + relationName = tn.FQString() + "@" + lexbase.EscapeSQLIdent(primaryIndexDesc.Name) return nil }); err != nil { return err