diff --git a/components/cdc/src/delegate.rs b/components/cdc/src/delegate.rs index fe7aa80e9f6b..d8493aa13c89 100644 --- a/components/cdc/src/delegate.rs +++ b/components/cdc/src/delegate.rs @@ -559,7 +559,7 @@ fn decode_write(key: Vec, value: &[u8], row: &mut EventRow) -> bool { WriteType::Delete => (EventRowOpType::Delete, EventLogType::Commit), WriteType::Rollback => (EventRowOpType::Unknown, EventLogType::Rollback), other => { - info!("skip write record"; "write" => ?other); + info!("skip write record"; "write" => ?other, "key" => hex::encode_upper(key.clone())); return true; } }; @@ -590,6 +590,7 @@ fn decode_lock(key: Vec, value: &[u8], row: &mut EventRow) -> bool { info!("skip lock record"; "type" => ?other, "start_ts" => ?lock.ts, + "key" => hex::encode_upper(key.clone()), "for_update_ts" => ?lock.for_update_ts); return true; } diff --git a/components/resolved_ts/src/lib.rs b/components/resolved_ts/src/lib.rs index f71c6a3901d6..76e3b08d0ccd 100644 --- a/components/resolved_ts/src/lib.rs +++ b/components/resolved_ts/src/lib.rs @@ -44,7 +44,7 @@ impl Resolver { } pub fn track_lock(&mut self, start_ts: TimeStamp, key: Vec) { - debug!( + info!( "track lock {}@{}, region {}", hex::encode_upper(key.clone()), start_ts, @@ -59,7 +59,7 @@ impl Resolver { commit_ts: Option, key: Vec, ) { - debug!( + info!( "untrack lock {}@{}, commit@{}, region {}", hex::encode_upper(key.clone()), start_ts,