Skip to content

Commit

Permalink
add log
Browse files Browse the repository at this point in the history
Signed-off-by: 5kbpers <tangminghua@pingcap.com>
  • Loading branch information
5kbpers committed Mar 29, 2020
1 parent 6488fe6 commit 5f79417
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
3 changes: 2 additions & 1 deletion components/cdc/src/delegate.rs
Expand Up @@ -559,7 +559,7 @@ fn decode_write(key: Vec<u8>, 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;
}
};
Expand Down Expand Up @@ -590,6 +590,7 @@ fn decode_lock(key: Vec<u8>, 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;
}
Expand Down
4 changes: 2 additions & 2 deletions components/resolved_ts/src/lib.rs
Expand Up @@ -44,7 +44,7 @@ impl Resolver {
}

pub fn track_lock(&mut self, start_ts: TimeStamp, key: Vec<u8>) {
debug!(
info!(
"track lock {}@{}, region {}",
hex::encode_upper(key.clone()),
start_ts,
Expand All @@ -59,7 +59,7 @@ impl Resolver {
commit_ts: Option<TimeStamp>,
key: Vec<u8>,
) {
debug!(
info!(
"untrack lock {}@{}, commit@{}, region {}",
hex::encode_upper(key.clone()),
start_ts,
Expand Down

0 comments on commit 5f79417

Please sign in to comment.