From 22c0351c20ee98c2679714966e55f986f607c394 Mon Sep 17 00:00:00 2001 From: John Spray Date: Tue, 19 Dec 2023 17:04:36 +0000 Subject: [PATCH] pageserver: fix records_committed metric --- pageserver/src/import_datadir.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/pageserver/src/import_datadir.rs b/pageserver/src/import_datadir.rs index fea32a6662..cf5d056bdd 100644 --- a/pageserver/src/import_datadir.rs +++ b/pageserver/src/import_datadir.rs @@ -21,6 +21,7 @@ use tracing::*; use walkdir::WalkDir; use crate::context::RequestContext; +use crate::metrics::WAL_INGEST; use crate::pgdatadir_mapping::*; use crate::tenant::remote_timeline_client::INITDB_PATH; use crate::tenant::Timeline; @@ -319,7 +320,10 @@ async fn import_wal( walingest .ingest_record(recdata, lsn, &mut modification, &mut decoded, ctx) .await?; + modification.commit(ctx).await?; + WAL_INGEST.records_committed.inc(); + last_lsn = lsn; nrecords += 1; @@ -457,6 +461,7 @@ pub async fn import_wal_from_tar( .ingest_record(recdata, lsn, &mut modification, &mut decoded, ctx) .await?; modification.commit(ctx).await?; + WAL_INGEST.records_committed.inc(); last_lsn = lsn; debug!("imported record at {} (end {})", lsn, end_lsn);