diff --git a/src/backend/catalog/pg_subscription.c b/src/backend/catalog/pg_subscription.c index 0ff0982f7b..08983db288 100644 --- a/src/backend/catalog/pg_subscription.c +++ b/src/backend/catalog/pg_subscription.c @@ -70,7 +70,7 @@ GetSubscription(Oid subid, bool missing_ok) sub->stream = subform->substream; sub->twophasestate = subform->subtwophasestate; sub->disableonerr = subform->subdisableonerr; - sub->skiplsn = subform->subskiplsn; + sub->skiplsn = DatumGetLSN(subform->subskiplsn); /* Get conninfo */ datum = SysCacheGetAttr(SUBSCRIPTIONOID,