Fix broken variable declaration

Author: Konstantin Knizhnik

diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
index 13af48524ab987a2218b35f74b05df72b843f367..f0bc67c7f5ee711bef833322ba9ac943134a9e0d 100644 (file)
--- a/src/backend/replication/logical/decode.c
+++ b/src/backend/replication/logical/decode.c
@@ -476,7 +476,7 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 {
    XLogRecPtr  origin_lsn = InvalidXLogRecPtr;
    TimestampTz commit_time = parsed->xact_time;
-   XLogRecPtr  origin_id = XLogRecGetOrigin(buf->record);
+   RepOriginId origin_id = XLogRecGetOrigin(buf->record);
    int         i;
 
    if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)