diff --git a/agent/src/flow_generator/protocol_logs/sql/sql_obfuscate.rs b/agent/src/flow_generator/protocol_logs/sql/sql_obfuscate.rs index 0cfc9b3b8e8..02d0c3d0214 100644 --- a/agent/src/flow_generator/protocol_logs/sql/sql_obfuscate.rs +++ b/agent/src/flow_generator/protocol_logs/sql/sql_obfuscate.rs @@ -94,7 +94,8 @@ impl Obfuscator { .map(|l| l.len()) .sum::() + (location.column as usize).saturating_sub(1); - let truncated = &sql[..byte_offset.min(sql.len())]; + let byte_offset = byte_offset.min(sql.len()); + let truncated = &sql[..sql.floor_char_boundary(byte_offset)]; let mut tokens = Tokenizer::new(&dialect, truncated) .with_unescape(false) .tokenize()?;