diff --git a/datafusion/physical-plan/src/aggregates/row_hash.rs b/datafusion/physical-plan/src/aggregates/row_hash.rs
index a4c0e33f3fc7..a7d58c95281b 100644
--- a/datafusion/physical-plan/src/aggregates/row_hash.rs
+++ b/datafusion/physical-plan/src/aggregates/row_hash.rs
@@ -660,7 +660,7 @@ impl GroupedHashAggregateStream {
                         }
                     }
                 }
-                let batch = RecordBatch::try_new(schema.clone(), output)?;
+                let batch = RecordBatch::try_new(Arc::clone(&schema), output)?;
                 batches.push_back(batch);
             }