From c3f06296a7057ccd5c2d4c15fdbe8719d2890b54 Mon Sep 17 00:00:00 2001 From: zhang2014 Date: Thu, 25 Dec 2025 18:32:21 +0800 Subject: [PATCH 1/2] refactor(query): use unchecked utf8 for payload flush --- src/query/expression/src/aggregate/payload_flush.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/query/expression/src/aggregate/payload_flush.rs b/src/query/expression/src/aggregate/payload_flush.rs index 72c18e3695ac7..faccecf464256 100644 --- a/src/query/expression/src/aggregate/payload_flush.rs +++ b/src/query/expression/src/aggregate/payload_flush.rs @@ -312,7 +312,7 @@ impl Payload { unsafe { for idx in 0..len { let scalar = state.addresses[idx].read_bytes(col_offset); - binary_builder.put_and_commit(std::str::from_utf8(scalar).unwrap()); + binary_builder.put_and_commit(std::str::from_utf8_unchecked(scalar).unwrap()); } } binary_builder.build() From 64801c6345a345137d9c37c8f44ae386de1b665b Mon Sep 17 00:00:00 2001 From: zhang2014 Date: Thu, 25 Dec 2025 19:14:49 +0800 Subject: [PATCH 2/2] z --- src/query/expression/src/aggregate/payload_flush.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/query/expression/src/aggregate/payload_flush.rs b/src/query/expression/src/aggregate/payload_flush.rs index faccecf464256..f8f8bc5850bd2 100644 --- a/src/query/expression/src/aggregate/payload_flush.rs +++ b/src/query/expression/src/aggregate/payload_flush.rs @@ -312,7 +312,7 @@ impl Payload { unsafe { for idx in 0..len { let scalar = state.addresses[idx].read_bytes(col_offset); - binary_builder.put_and_commit(std::str::from_utf8_unchecked(scalar).unwrap()); + binary_builder.put_and_commit(std::str::from_utf8_unchecked(scalar)); } } binary_builder.build()