diff --git a/src/backend/executor/tqueue.c b/src/backend/executor/tqueue.c
index a729372c740d431afe45e203c145c450ea0ed8bd..d29fd2afde430c8e51ec058d7a02b55d97972bea 100644
--- a/src/backend/executor/tqueue.c
+++ b/src/backend/executor/tqueue.c
@@ -402,7 +402,8 @@ tqueueSendTypmodInfo(TQueueDestReceiver *tqueue, int typmod,
 		ctl.entrysize = sizeof(int);
 		ctl.hcxt = TopMemoryContext;
 		tqueue->recordhtab = hash_create("tqueue record hashtable",
-										 100, &ctl, HASH_ELEM | HASH_CONTEXT);
+										 100, &ctl,
+									  HASH_ELEM | HASH_BLOBS | HASH_CONTEXT);
 	}
 
 	/* Have we already seen this record type?  If not, must report it. */
@@ -877,7 +878,8 @@ TupleQueueHandleControlMessage(TupleQueueReader *reader, Size nbytes,
 		ctl.entrysize = sizeof(RecordTypemodMap);
 		ctl.hcxt = CurTransactionContext;
 		reader->typmodmap = hash_create("typmodmap hashtable",
-										100, &ctl, HASH_ELEM | HASH_CONTEXT);
+										100, &ctl,
+									  HASH_ELEM | HASH_BLOBS | HASH_CONTEXT);
 	}
 
 	/* Create map entry. */