parTraverse actually

cognitedata · Dec 11, 2024 · 54431c0 · 54431c0
1 parent 03c025d
commit 54431c0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/cognite/spark/v1/RawTableRelation.scala b/src/main/scala/cognite/spark/v1/RawTableRelation.scala
@@ -290,7 +290,7 @@ class RawTableRelation(
         case Some(maxOutstandingRawInsertRequests) =>
           Backpressure[IO](Backpressure.Strategy.Lossless, maxOutstandingRawInsertRequests)
             .flatMap { backpressure =>
-              rows.grouped(batchSize).toVector.traverse_ { batch: Seq[Row] =>
+              rows.grouped(batchSize).toVector.parTraverse_ { batch: Seq[Row] =>
                 backpressure.metered(postRows(columnNames, batch))
               }
             }