From d4a81e6ebedda969e6234edf5b9cd0e3173777fa Mon Sep 17 00:00:00 2001 From: Bugen Zhao Date: Sun, 8 Oct 2023 13:42:14 +0800 Subject: [PATCH] add split id Signed-off-by: Bugen Zhao --- src/connector/src/parser/mod.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/connector/src/parser/mod.rs b/src/connector/src/parser/mod.rs index 04a6c3b0b2c05..5977a2561d1a3 100644 --- a/src/connector/src/parser/mod.rs +++ b/src/connector/src/parser/mod.rs @@ -512,9 +512,13 @@ async fn into_chunk_stream(mut parser: P, data_stream if msg.key.is_none() && msg.payload.is_none() { continue; } - split_offset_mapping.insert(msg.split_id, msg.offset.clone()); + let parse_span = tracing::info_span!( + "parse_one", + split_id = msg.split_id.as_ref(), + offset = msg.offset + ); - let parse_span = tracing::info_span!("parse_one", offset = msg.offset); + split_offset_mapping.insert(msg.split_id, msg.offset.clone()); let old_op_num = builder.op_num(); match parser