diff --git a/pgdog/src/backend/pool/lsn_monitor.rs b/pgdog/src/backend/pool/lsn_monitor.rs index 6b50f1794..c0998a608 100644 --- a/pgdog/src/backend/pool/lsn_monitor.rs +++ b/pgdog/src/backend/pool/lsn_monitor.rs @@ -49,7 +49,12 @@ SELECT ELSE now() END AS timestamp, - (pg_control_checkpoint()).timeline_id AS timeline + CASE + WHEN replica THEN + (pg_control_checkpoint()).timeline_id + ELSE + ('x' || substr(pg_walfile_name(lsn), 1, 8))::bit(32)::int + END AS timeline FROM wal ";