Fix field count.

diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c
index 794f5f15526d1d077dee31e0f1c785a200377447..1c593cefe3577449c63692d636123cff8390f7cb 100644 (file)
--- a/src/backend/replication/walsender.c
+++ b/src/backend/replication/walsender.c
@@ -678,7 +678,7 @@ CreateReplicationSlot(CreateReplicationSlotCmd *cmd)
 
        /* Send a DataRow message */
        pq_beginmessage(&buf, 'D');
-       pq_sendint(&buf, 4, 2);         /* # of columns */
+       pq_sendint(&buf, 1, 2);         /* # of columns */
 
        /* slot_name */
        pq_sendint(&buf, strlen(slot_name), 4); /* col1 len */