diff --git a/src/backend/distributed/commands/transmit.c b/src/backend/distributed/commands/transmit.c
index 8ce727017..be6f56d0d 100644
--- a/src/backend/distributed/commands/transmit.c
+++ b/src/backend/distributed/commands/transmit.c
@@ -245,7 +245,7 @@ static bool
 ReceiveCopyData(StringInfo copyData)
 {
 	bool copyDone = true;
-	const int unlimitedSize = 0;
+	const int unlimitedSize = PQ_LARGE_MESSAGE_LIMIT;
 
 	HOLD_CANCEL_INTERRUPTS();
 	pq_startmsgread();
diff --git a/src/include/distributed/version_compat.h b/src/include/distributed/version_compat.h
index 960ef8eef..fba6cfe99 100644
--- a/src/include/distributed/version_compat.h
+++ b/src/include/distributed/version_compat.h
@@ -93,6 +93,7 @@
 	((&ProcGlobal->allPgXact[(pgproc)->pgprocno])->vacuumFlags)
 #define get_partition_parent_compat(a, b) get_partition_parent(a)
 #define RelationGetPartitionDesc_compat(a, b) RelationGetPartitionDesc(a)
+#define PQ_LARGE_MESSAGE_LIMIT 0
 #endif
 
 #if PG_VERSION_NUM >= PG_VERSION_13