diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c
index 819b35cf2..d701ac8f6 100644
--- a/src/backend/distributed/connection/connection_management.c
+++ b/src/backend/distributed/connection/connection_management.c
@@ -1237,6 +1237,14 @@ ConnectionHashHash(const void *key, Size keysize)
 	hash = hash_combine(hash, hash_uint32(entry->port));
 	hash = hash_combine(hash, string_hash(entry->user, NAMEDATALEN));
 	hash = hash_combine(hash, string_hash(entry->database, NAMEDATALEN));
+	if (entry->replicationConnParam)
+	{
+		hash = hash_combine(hash, hash_uint32(1));
+	}
+	else
+	{
+		hash = hash_combine(hash, hash_uint32(0));
+	}
 
 	return hash;
 }