diff --git a/tests/performance/array_reduce.xml b/tests/performance/array_reduce.xml
index 8e271c155f3..0f50eba43bf 100644
--- a/tests/performance/array_reduce.xml
+++ b/tests/performance/array_reduce.xml
@@ -1,11 +1,8 @@
 <test>
-
-
-
-    <query>SELECT arrayReduce('count', range(100000000))</query>
-    <query>SELECT arrayReduce('sum', range(100000000))</query>
-    <query>SELECT arrayReduceInRanges('count', [(1, 100000000)], range(100000000))</query>
-    <query>SELECT arrayReduceInRanges('sum', [(1, 100000000)], range(100000000))</query>
-    <query>SELECT arrayReduceInRanges('count', arrayZip(range(1000000), range(1000000)), range(100000000))[123456]</query>
-    <query>SELECT arrayReduceInRanges('sum', arrayZip(range(1000000), range(1000000)), range(100000000))[123456]</query>
+    <query>SELECT arrayReduce('count', range(1000000)) FROM numbers_mt(500000000) format Null</query>
+    <query>SELECT arrayReduce('sum', range(1000000)) FROM numbers_mt(500000000) format Null</query>
+    <query>SELECT arrayReduceInRanges('count', [(1, 1000000)], range(1000000)) FROM numbers_mt(500000000) format Null</query>
+    <query>SELECT arrayReduceInRanges('sum', [(1, 1000000)], range(1000000)) FROM numbers_mt(500000000) format Null</query>
+    <query>SELECT arrayReduceInRanges('count', arrayZip(range(1000000), range(1000000)), range(1000000))[123456]</query>
+    <query>SELECT arrayReduceInRanges('sum', arrayZip(range(1000000), range(1000000)), range(1000000))[123456]</query>
 </test>
diff --git a/tests/performance/scripts/perf.py b/tests/performance/scripts/perf.py
index 94f145d82db..f89784a0e0b 100755
--- a/tests/performance/scripts/perf.py
+++ b/tests/performance/scripts/perf.py
@@ -345,6 +345,18 @@ for query_index in queries_to_run:
 
     print(f"display-name\t{query_index}\t{tsv_escape(query_display_name)}")
 
+    for conn_index, c in enumerate(all_connections):
+        try:
+            c.execute("SYSTEM JEMALLOC PURGE")
+
+            print(
+                f"purging jemalloc arenas\t{conn_index}\t{c.last_query.elapsed}"
+            )
+        except KeyboardInterrupt:
+            raise
+        except:
+            continue
+
     # Prewarm: run once on both servers. Helps to bring the data into memory,
     # precompile the queries, etc.
     # A query might not run on the old server if it uses a function added in the
@@ -427,8 +439,6 @@ for query_index in queries_to_run:
 
         for conn_index, c in enumerate(this_query_connections):
             try:
-                c.execute("SYSTEM JEMALLOC PURGE")
-
                 res = c.execute(
                     q,
                     query_id=run_id,