diff --git a/columnar/src/backend/columnar/columnar_metadata.c b/columnar/src/backend/columnar/columnar_metadata.c index e2a91929..e60c1055 100644 --- a/columnar/src/backend/columnar/columnar_metadata.c +++ b/columnar/src/backend/columnar/columnar_metadata.c @@ -1093,7 +1093,7 @@ FindNextStripeForParallelWorker(Relation relation, ScanKeyData scanKey; ScanKeyInit(&scanKey, Anum_columnar_stripe_storageid, - BTEqualStrategyNumber, F_OIDEQ, Int32GetDatum(storageId)); + BTEqualStrategyNumber, F_OIDEQ, UInt64GetDatum(storageId)); Relation columnarStripes = table_open(ColumnarStripeRelationId(), AccessShareLock); @@ -1120,6 +1120,8 @@ FindNextStripeForParallelWorker(Relation relation, *nextHigherStripeId = foundStripeMetadata->id; break; } + + pfree(foundStripeMetadata); } else {