postgres
diff --git a/‎src/backend/replication/pgoutput/pgoutput.c
Copy file name to clipboardExpand all lines: src/backend/replication/pgoutput/pgoutput.c
+10Lines changed: 10 additions & 0 deletions b/‎src/backend/replication/pgoutput/pgoutput.c
Copy file name to clipboardExpand all lines: src/backend/replication/pgoutput/pgoutput.c
+10Lines changed: 10 additions & 0 deletions
@@ -1554,6 +1554,16 @@ pgoutput_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 		ancestor = NULL;
 	}
 
+	/* Drop the new slots that were used to store the converted tuples. */
+	if (relentry->attrmap)
+	{
+		if (old_slot)
+			ExecDropSingleTupleTableSlot(old_slot);
+
+		if (new_slot)
+			ExecDropSingleTupleTableSlot(new_slot);
+	}
+
 	MemoryContextSwitchTo(old);
 	MemoryContextReset(data->context);
 }