diff --git a/safekeeper/src/receive_wal.rs b/safekeeper/src/receive_wal.rs index 6577e8c4d6..be7f071abb 100644 --- a/safekeeper/src/receive_wal.rs +++ b/safekeeper/src/receive_wal.rs @@ -52,7 +52,7 @@ impl<'pg> ReceiveWalConn<'pg> { /// Receive WAL from wal_proposer pub fn run(&mut self, spg: &mut SafekeeperPostgresHandler) -> Result<()> { - let _enter = info_span!("WAL acceptor", timeline = %spg.timeline_id.unwrap()).entered(); + let _enter = info_span!("WAL acceptor", ttid = %spg.ttid).entered(); // Notify the libpq client that it's allowed to send `CopyData` messages self.pg_backend @@ -69,7 +69,7 @@ impl<'pg> ReceiveWalConn<'pg> { let tli = match next_msg { ProposerAcceptorMessage::Greeting(ref greeting) => { info!( - "start handshake with wal proposer {} sysid {} timeline {}", + "start handshake with walproposer {} sysid {} timeline {}", self.peer_addr, greeting.system_id, greeting.tli, ); let server_info = ServerInfo { diff --git a/safekeeper/src/safekeeper.rs b/safekeeper/src/safekeeper.rs index 5b1b686529..fa973a3ede 100644 --- a/safekeeper/src/safekeeper.rs +++ b/safekeeper/src/safekeeper.rs @@ -634,10 +634,12 @@ where // system_id will be updated on mismatch if self.state.server.system_id != msg.system_id { - warn!( - "unexpected system ID arrived, got {}, expected {}", - msg.system_id, self.state.server.system_id - ); + if self.state.server.system_id != 0 { + warn!( + "unexpected system ID arrived, got {}, expected {}", + msg.system_id, self.state.server.system_id + ); + } let mut state = self.state.clone(); state.server.system_id = msg.system_id; @@ -648,8 +650,9 @@ where } info!( - "processed greeting from proposer {:?}, sending term {:?}", - msg.proposer_id, self.state.acceptor_state.term + "processed greeting from walproposer {}, sending term {:?}", + msg.proposer_id.map(|b| format!("{:X}", b)).join(""), + self.state.acceptor_state.term ); Ok(Some(AcceptorProposerMessage::Greeting(AcceptorGreeting { term: self.state.acceptor_state.term, diff --git a/safekeeper/src/send_wal.rs b/safekeeper/src/send_wal.rs index a3481430d0..a054b8fe14 100644 --- a/safekeeper/src/send_wal.rs +++ b/safekeeper/src/send_wal.rs @@ -161,7 +161,7 @@ impl ReplicationConn { pgb: &mut PostgresBackend, mut start_pos: Lsn, ) -> Result<()> { - let _enter = info_span!("WAL sender", timeline = %spg.timeline_id.unwrap()).entered(); + let _enter = info_span!("WAL sender", ttid = %spg.ttid).entered(); let tli = GlobalTimelines::get(spg.ttid)?;