diff --git a/lib/collection/src/shards/transfer/stream_records.rs b/lib/collection/src/shards/transfer/stream_records.rs
index 1af92c4749..af23914fde 100644
--- a/lib/collection/src/shards/transfer/stream_records.rs
+++ b/lib/collection/src/shards/transfer/stream_records.rs
@@ -84,7 +84,7 @@ pub(super) async fn transfer_stream_records(
         };
 
         replica_set
-            .proxify_local(remote_shard.clone(), None, filter)
+            .proxify_local(remote_shard.clone(), None, filter.clone())
             .await?;
 
         // Don't increment hardware usage for internal operations
@@ -92,7 +92,7 @@ pub(super) async fn transfer_stream_records(
         let Some(count_result) = replica_set
             .count_local(
                 Arc::new(CountRequestInternal {
-                    filter: None,
+                    filter,
                     exact: false,
                 }),
                 None, // no timeout