Repository: beam Updated Branches: refs/heads/master 88ec00860 -> 926157d42
Fix GcsResourceIdTest in postcommits This test is not a @ValidatesRunner test, so it should not use TestPipelineOptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15ec2cd8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/15ec2cd8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/15ec2cd8 Branch: refs/heads/master Commit: 15ec2cd83d4291957a75d9f2ac838ff867dcbe0c Parents: 88ec008 Author: Dan Halperin <dhalp...@google.com> Authored: Mon May 15 10:57:24 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Mon May 15 13:11:48 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/15ec2cd8/sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java b/sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java index c1e214e..ae7d40c 100644 --- a/sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java +++ b/sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java @@ -26,7 +26,7 @@ import org.apache.beam.sdk.io.FileSystems; import org.apache.beam.sdk.io.fs.ResolveOptions.StandardResolveOptions; import org.apache.beam.sdk.io.fs.ResourceId; import org.apache.beam.sdk.io.fs.ResourceIdTester; -import org.apache.beam.sdk.testing.TestPipeline; +import org.apache.beam.sdk.options.PipelineOptionsFactory; import org.apache.beam.sdk.util.gcsfs.GcsPath; import org.junit.Rule; import org.junit.Test; @@ -168,7 +168,7 @@ public class GcsResourceIdTest { @Test public void testResourceIdTester() throws Exception { - FileSystems.setDefaultPipelineOptions(TestPipeline.testingPipelineOptions()); + FileSystems.setDefaultPipelineOptions(PipelineOptionsFactory.create()); ResourceIdTester.runResourceIdBattery(toResourceIdentifier("gs://bucket/foo/")); }
