Repository: beam Updated Branches: refs/heads/master 8e85b6b37 -> 8e391d94f
Fix GqlQueryTranslateFn to pass localhost option to DatastoreFactory Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97b17b68 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/97b17b68 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/97b17b68 Branch: refs/heads/master Commit: 97b17b685c427e68b3585f70cc2189c4ff03e615 Parents: 8e85b6b Author: Alexander Hoem Rosbach <[email protected]> Authored: Mon Aug 21 15:03:32 2017 +0200 Committer: [email protected] <[email protected]> Committed: Tue Sep 12 10:28:35 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/97b17b68/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java ---------------------------------------------------------------------- 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 5843333..04f02fc 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 @@ -737,7 +737,8 @@ public class DatastoreV1 { @StartBundle public void startBundle(StartBundleContext c) throws Exception { - datastore = datastoreFactory.getDatastore(c.getPipelineOptions(), v1Options.getProjectId()); + datastore = datastoreFactory.getDatastore(c.getPipelineOptions(), v1Options.getProjectId(), + v1Options.getLocalhost()); } @ProcessElement
