You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/10/11 00:35:28 UTC
[1/2] incubator-beam git commit: [BEAM-736] Fix BigQueryTornadoesIT,
broken by PR-1039
Repository: incubator-beam
Updated Branches:
refs/heads/master c7c13157f -> daf69f87e
[BEAM-736] Fix BigQueryTornadoesIT, broken by PR-1039
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1d3f31da
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1d3f31da
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1d3f31da
Branch: refs/heads/master
Commit: 1d3f31da7ee9769200e8a93ec3626cd4cd636f67
Parents: c7c1315
Author: Pei He <pe...@google.com>
Authored: Mon Oct 10 14:30:30 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Oct 10 17:28:19 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1d3f31da/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
index 3d1aba6..5aa952c 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
@@ -542,11 +542,11 @@ public class BigQueryIO {
// For these cases the withoutValidation method can be used to disable the check.
if (validate && table != null) {
// Check for source table presence for early failure notification.
- DatasetService datasetService = bigQueryServices.getDatasetService(bqOptions);
+ DatasetService datasetService = getBigQueryServices().getDatasetService(bqOptions);
verifyDatasetPresence(datasetService, table);
verifyTablePresence(datasetService, table);
} else if (validate && query != null) {
- JobService jobService = bigQueryServices.getJobService(bqOptions);
+ JobService jobService = getBigQueryServices().getJobService(bqOptions);
try {
jobService.dryRunQuery(
bqOptions.getProject(),
[2/2] incubator-beam git commit: [BEAM-736] Fix BigQueryTornadoesIT,
broken by PR-1039
Posted by lc...@apache.org.
[BEAM-736] Fix BigQueryTornadoesIT, broken by PR-1039
This closes #1078
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/daf69f87
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/daf69f87
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/daf69f87
Branch: refs/heads/master
Commit: daf69f87e7271b2620e9bc023a8a360a485f856a
Parents: c7c1315 1d3f31d
Author: Luke Cwik <lc...@google.com>
Authored: Mon Oct 10 17:28:52 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Oct 10 17:28:52 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------