Don't call .testingPipelineOptions() a second time
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ab7f6f6d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ab7f6f6d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ab7f6f6d Branch: refs/heads/master Commit: ab7f6f6dbd3ad67c5da577bc9395cb09e35069d9 Parents: 0acfe70 Author: Stephen Sisk <s...@google.com> Authored: Thu Jun 29 13:29:22 2017 -0700 Committer: Stephen Sisk <s...@google.com> Committed: Thu Jun 29 13:29:22 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java | 2 +- .../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java | 2 +- .../java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java | 2 +- .../java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/ab7f6f6d/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java index e47fd0f..91f0bae 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java @@ -42,7 +42,7 @@ public class BigtableReadIT { BigtableTestOptions options = TestPipeline.testingPipelineOptions() .as(BigtableTestOptions.class); - String project = TestPipeline.testingPipelineOptions().as(GcpOptions.class).getProject(); + String project = options.as(GcpOptions.class).getProject(); BigtableOptions.Builder bigtableOptionsBuilder = new BigtableOptions.Builder() .setProjectId(project) http://git-wip-us.apache.org/repos/asf/beam/blob/ab7f6f6d/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java index 72ba836..010bcc4 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java @@ -79,7 +79,7 @@ public class BigtableWriteIT implements Serializable { public void setup() throws Exception { PipelineOptionsFactory.register(BigtableTestOptions.class); options = TestPipeline.testingPipelineOptions().as(BigtableTestOptions.class); - project = TestPipeline.testingPipelineOptions().as(GcpOptions.class).getProject(); + project = options.as(GcpOptions.class).getProject(); bigtableOptions = new Builder() http://git-wip-us.apache.org/repos/asf/beam/blob/ab7f6f6d/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java index 32183f9..bfbda50 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java @@ -88,7 +88,7 @@ public class SpannerReadIT { PipelineOptionsFactory.register(SpannerTestPipelineOptions.class); options = TestPipeline.testingPipelineOptions().as(SpannerTestPipelineOptions.class); - project = TestPipeline.testingPipelineOptions().as(GcpOptions.class).getProject(); + project = options.as(GcpOptions.class).getProject(); spanner = SpannerOptions.newBuilder().setProjectId(project).build().getService(); http://git-wip-us.apache.org/repos/asf/beam/blob/ab7f6f6d/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java index 78a360f..436d01e 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java @@ -87,7 +87,7 @@ public class SpannerWriteIT { PipelineOptionsFactory.register(SpannerTestPipelineOptions.class); options = TestPipeline.testingPipelineOptions().as(SpannerTestPipelineOptions.class); - project = TestPipeline.testingPipelineOptions().as(GcpOptions.class).getProject(); + project = options.as(GcpOptions.class).getProject(); spanner = SpannerOptions.newBuilder().setProjectId(project).build().getService();
