This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 3c4a200 [BEAM-3502] Remove usage of proto.Builder.clone() in
DatastoreIO (#4449)
3c4a200 is described below
commit 3c4a2001e5364657f6596bfc338f792e4797712d
Author: Exprosed <[email protected]>
AuthorDate: Fri Jan 19 20:45:51 2018 -0500
[BEAM-3502] Remove usage of proto.Builder.clone() in DatastoreIO (#4449)
---
.../src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java
index 9b20c0d..7528dde 100644
---
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java
+++
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java
@@ -890,7 +890,7 @@ public class DatastoreV1 {
QueryResultBatch currentBatch = null;
while (moreResults) {
- Query.Builder queryBuilder = query.toBuilder().clone();
+ Query.Builder queryBuilder = query.toBuilder();
queryBuilder.setLimit(Int32Value.newBuilder().setValue(
Math.min(userLimit, QUERY_BATCH_LIMIT)));
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].