diff --git a/src/backend/columnar/columnar_metadata.c b/src/backend/columnar/columnar_metadata.c index e3264311c..cc47744ba 100644 --- a/src/backend/columnar/columnar_metadata.c +++ b/src/backend/columnar/columnar_metadata.c @@ -1510,6 +1510,8 @@ ReadDataFileStripeList(uint64 storageId, Snapshot snapshot) Oid indexId = ColumnarStripeFirstRowNumberIndexRelationId(); bool indexOk = OidIsValid(indexId); + + snapshot = RegisterSnapshot(snapshot); SysScanDesc scanDescriptor = systable_beginscan(columnarStripes, indexId, indexOk, snapshot, 1, scanKey); @@ -1529,6 +1531,7 @@ ReadDataFileStripeList(uint64 storageId, Snapshot snapshot) systable_endscan(scanDescriptor); table_close(columnarStripes, AccessShareLock); + UnregisterSnapshot(snapshot); return stripeMetadataList; }