This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 82c4586d3 bigquery: use fromArrayUnsafe (#665)
82c4586d3 is described below
commit 82c4586d3c03be86a88f4106d318ad9c965015d0
Author: PJ Fanning <[email protected]>
AuthorDate: Sun May 19 15:53:54 2024 +0100
bigquery: use fromArrayUnsafe (#665)
---
.../googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
index 1292c9387..2d6e02ccf 100644
---
a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
+++
b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
@@ -75,7 +75,7 @@ object BigQueryStorage {
resp.arrowRecordBatch.get.serializedRecordBatch
else
resp.avroRows.get.serializedBinaryRows
- um(ByteString(bytes.toByteArray))
+ um(ByteString.fromArrayUnsafe(bytes.toByteArray))
})
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
