From d1231431d6b65fad25bd85f0a707d3af40ec77e0 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Wed, 7 Aug 2024 14:34:43 +0300 Subject: [PATCH] Bump Postgres version --- pageserver/src/walingest.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pageserver/src/walingest.rs b/pageserver/src/walingest.rs index 623870c59f..344cda4e0f 100644 --- a/pageserver/src/walingest.rs +++ b/pageserver/src/walingest.rs @@ -235,6 +235,7 @@ impl WalIngest { &parsed_xact, info == pg_constants::XLOG_XACT_COMMIT, decoded.origin_id, + lsn, ctx, ) .await?; @@ -248,6 +249,7 @@ impl WalIngest { &parsed_xact, info == pg_constants::XLOG_XACT_COMMIT_PREPARED, decoded.origin_id, + lsn, ctx, ) .await?; @@ -1225,6 +1227,7 @@ impl WalIngest { parsed: &XlXactParsedRecord, is_commit: bool, origin_id: u16, + lsn: Lsn, ctx: &RequestContext, ) -> anyhow::Result<()> { // Record update of CLOG pages @@ -1292,8 +1295,8 @@ impl WalIngest { } if origin_id != 0 { info!( - "Commit origin_id={}, origin_lsn={}", - origin_id, parsed.origin_lsn + "Commit at {} origin_id={}, origin_lsn={}", + lsn, origin_id, parsed.origin_lsn ); modification .set_replorigin(origin_id, parsed.origin_lsn)