Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit a811ea5

Browse files
Handle new HOT chains in index-build table scans
When a table is scanned by heapam_index_build_range_scan (née IndexBuildHeapScan) and the table lock being held allows concurrent data changes, it is possible for new HOT chains to sprout in a page that were unknown when the scan of a page happened. This leads to an error such as ERROR: failed to find parent tuple for heap-only tuple at (X,Y) in table "tbl" because the root tuple was not present when we first obtained the list of the page's root tuples. This can be fixed by re-obtaining the list of root tuples, if we see that a heap-only tuple appears to point to a non-existing root. This was reported by Anastasia as occurring for BRIN summarization (which exists since 9.5), but I think it could theoretically also happen with CREATE INDEX CONCURRENTLY (much older) or REINDEX CONCURRENTLY (very recent). It seems a happy coincidence that BRIN forces us to backpatch this all the way to 9.5. Reported-by: Anastasia Lubennikova <a.lubennikova@postgrespro.ru> Diagnosed-by: Anastasia Lubennikova <a.lubennikova@postgrespro.ru> Co-authored-by: Anastasia Lubennikova <a.lubennikova@postgrespro.ru> Co-authored-by: Álvaro Herrera <alvherre@alvh.no-ip.org> Discussion: https://postgr.es/m/602d8487-f0b2-5486-0088-0f372b2549fa@postgrespro.ru Backpatch: 9.5 - master
1 parent b8443ea commit a811ea5

File tree

2 files changed

+23
-2
lines changed

2 files changed

+23
-2
lines changed

src/backend/access/heap/heapam_handler.c

+20
Original file line numberDiff line numberDiff line change
@@ -1324,6 +1324,12 @@ heapam_index_build_range_scan(Relation heapRelation,
13241324
* buffer continuously while visiting the page, so no pruning
13251325
* operation can occur either.
13261326
*
1327+
* In cases with only ShareUpdateExclusiveLock on the table, it's
1328+
* possible for some HOT tuples to appear that we didn't know about
1329+
* when we first read the page. To handle that case, we re-obtain the
1330+
* list of root offsets when a HOT tuple points to a root item that we
1331+
* don't know about.
1332+
*
13271333
* Also, although our opinions about tuple liveness could change while
13281334
* we scan the page (due to concurrent transaction commits/aborts),
13291335
* the chain root locations won't, so this info doesn't need to be
@@ -1625,6 +1631,20 @@ heapam_index_build_range_scan(Relation heapRelation,
16251631

16261632
offnum = ItemPointerGetOffsetNumber(&heapTuple->t_self);
16271633

1634+
/*
1635+
* If a HOT tuple points to a root that we don't know
1636+
* about, obtain root items afresh. If that still fails,
1637+
* report it as corruption.
1638+
*/
1639+
if (root_offsets[offnum - 1] == InvalidOffsetNumber)
1640+
{
1641+
Page page = BufferGetPage(hscan->rs_cbuf);
1642+
1643+
LockBuffer(hscan->rs_cbuf, BUFFER_LOCK_SHARE);
1644+
heap_get_root_tuples(page, root_offsets);
1645+
LockBuffer(hscan->rs_cbuf, BUFFER_LOCK_UNLOCK);
1646+
}
1647+
16281648
if (!OffsetNumberIsValid(root_offsets[offnum - 1]))
16291649
ereport(ERROR,
16301650
(errcode(ERRCODE_DATA_CORRUPTED),

src/backend/access/heap/pruneheap.c

+3-2
Original file line numberDiff line numberDiff line change
@@ -855,7 +855,7 @@ heap_page_prune_execute(Buffer buffer,
855855
* root_offsets[k - 1] = j.
856856
*
857857
* The passed-in root_offsets array must have MaxHeapTuplesPerPage entries.
858-
* We zero out all unused entries.
858+
* Unused entries are filled with InvalidOffsetNumber (zero).
859859
*
860860
* The function must be called with at least share lock on the buffer, to
861861
* prevent concurrent prune operations.
@@ -870,7 +870,8 @@ heap_get_root_tuples(Page page, OffsetNumber *root_offsets)
870870
OffsetNumber offnum,
871871
maxoff;
872872

873-
MemSet(root_offsets, 0, MaxHeapTuplesPerPage * sizeof(OffsetNumber));
873+
MemSet(root_offsets, InvalidOffsetNumber,
874+
MaxHeapTuplesPerPage * sizeof(OffsetNumber));
874875

875876
maxoff = PageGetMaxOffsetNumber(page);
876877
for (offnum = FirstOffsetNumber; offnum <= maxoff; offnum = OffsetNumberNext(offnum))

0 commit comments

Comments
 (0)