Skip to content

Commit

Permalink
chore: fix typos and change log level
Browse files Browse the repository at this point in the history
  • Loading branch information
iamazy committed Jan 31, 2023
1 parent c18de1b commit 2e39ad4
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/records.rs
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ impl RecordBatchDecoder {
}
fn decode_batch<B: ByteBuf>(buf: &mut B, records: &mut Vec<Record>) -> Result<(), DecodeError> {
let version = buf.try_peek_bytes(MAGIC_BYTE_OFFSET..(MAGIC_BYTE_OFFSET+1))?[0] as i8;
info!("Decoding record batch (version: {})", version);
debug!("Decoding record batch (version: {})", version);
match version {
0..=1 => Record::decode_legacy(buf, version, records),
2 => Self::decode_new_batch(buf, version, records),
Expand Down Expand Up @@ -427,7 +427,7 @@ impl RecordBatchDecoder {
// Magic byte
let magic: i8 = types::Int8.decode(buf)?;
if magic != version {
error!("Version mismtach ({} != {})", magic, version);
error!("Version mismatch ({} != {})", magic, version);
return Err(DecodeError);
}

Expand Down Expand Up @@ -756,7 +756,7 @@ impl Record {
// Magic
let magic: i8 = types::Int8.decode(buf)?;
if magic != version {
error!("Version mismtach ({} != {})", magic, version);
error!("Version mismatch ({} != {})", magic, version);
return Err(DecodeError);
}

Expand Down

0 comments on commit 2e39ad4

Please sign in to comment.