diff --git a/src/backend/columnar/columnar_reader.c b/src/backend/columnar/columnar_reader.c index f0995bf8a..770636d59 100644 --- a/src/backend/columnar/columnar_reader.c +++ b/src/backend/columnar/columnar_reader.c @@ -211,7 +211,6 @@ ColumnarReadNextRow(ColumnarReadState *readState, Datum *columnValues, bool *col if (!ReadStripeNextRow(readState->stripeReadState, columnValues, columnNulls)) { - EndStripeRead(readState->stripeReadState); AdvanceStripeRead(readState); continue; } @@ -326,6 +325,8 @@ AdvanceStripeRead(ColumnarReadState *readState) { readState->chunkGroupsFiltered += readState->stripeReadState->chunkGroupsFiltered; + EndStripeRead(readState->stripeReadState); + readState->currentStripe++; readState->stripeReadState = NULL; MemoryContextReset(readState->stripeReadContext);