diff options
| -rw-r--r-- | src/backend/executor/producerReceiver.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/backend/executor/producerReceiver.c b/src/backend/executor/producerReceiver.c index 8dec452b6a..b7a7033833 100644 --- a/src/backend/executor/producerReceiver.c +++ b/src/backend/executor/producerReceiver.c @@ -57,6 +57,8 @@ producerStartupReceiver(DestReceiver *self, int operation, TupleDesc typeinfo) */ MemoryContext savecontext; savecontext = MemoryContextSwitchTo(PortalGetHeapMemory(ActivePortal)); + if (myState->typeinfo) + pfree(myState->typeinfo); myState->typeinfo = CreateTupleDescCopy(typeinfo); MemoryContextSwitchTo(savecontext); } |