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(),
