diff --git a/pkg/storage/client_split_test.go b/pkg/storage/client_split_test.go
index 3cafda5d4a3f..708f700584af 100644
--- a/pkg/storage/client_split_test.go
+++ b/pkg/storage/client_split_test.go
@@ -1166,6 +1166,17 @@ func runSetupSplitSnapshotRace(
 	// Store 3 still has the old value, but 4 and 5 are up to date.
 	mtc.waitForValues(rightKey, []int64{0, 0, 0, 2, 5, 5})
 
+	// Scan the meta ranges to resolve all intents
+	if _, pErr := client.SendWrapped(context.Background(), mtc.distSenders[0],
+		&roachpb.ScanRequest{
+			Span: roachpb.Span{
+				Key:    keys.MetaMin,
+				EndKey: keys.MetaMax,
+			},
+		}); pErr != nil {
+		t.Fatal(pErr)
+	}
+
 	// Stop the remaining data stores.
 	mtc.stopStore(1)
 	mtc.stopStore(2)
diff --git a/pkg/storage/client_test.go b/pkg/storage/client_test.go
index 494458ac7319..212f6c9f598b 100644
--- a/pkg/storage/client_test.go
+++ b/pkg/storage/client_test.go
@@ -476,6 +476,7 @@ func (t *multiTestContextKVTransport) SendNext(ctx context.Context, done chan<-
 		t.mtc.mu.RUnlock()
 		// Make a copy and clone txn of batch args for sending.
 		baCopy := t.args
+		baCopy.Replica = rep.ReplicaDescriptor
 		if txn := baCopy.Txn; txn != nil {
 			txnClone := baCopy.Txn.Clone()
 			baCopy.Txn = &txnClone