diff --git a/tests-integration/src/tests/native_aggregate_test.rs b/tests-integration/src/tests/native_aggregate_test.rs
index 4301ac3cd12..fcf032a2cc3 100644
--- a/tests-integration/src/tests/native_aggregate_test.rs
+++ b/tests-integration/src/tests/native_aggregate_test.rs
@@ -2144,7 +2144,7 @@ async fn native_aggregate_topk_over_global_partitions() {
         capture
             .fused
             .iter()
-            .map(|node| plan_text(node))
+            .map(plan_text)
             .collect::<Vec<_>>()
             .join("\n=====\n")
     );