diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go
index 8d4d5faf90..585ae0bc25 100644
--- a/flow/workflows/snapshot_flow.go
+++ b/flow/workflows/snapshot_flow.go
@@ -148,6 +148,9 @@ func (s *SnapshotFlowExecution) cloneTable(
 		SyncMode:                   s.config.SnapshotSyncMode,
 		MaxParallelWorkers:         numWorkers,
 		StagingPath:                s.config.SnapshotStagingPath,
+		WriteMode: &protos.QRepWriteMode{
+			WriteType: protos.QRepWriteType_QREP_WRITE_MODE_APPEND,
+		},
 	}
 
 	numPartitionsProcessed := 0