Repository: incubator-beam Updated Branches: refs/heads/master 2b8b20ded -> 3fe3bc8eb
Update BigQueryIO tests who expect failure to be NeedsRunner tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3a3ebc84 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3a3ebc84 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3a3ebc84 Branch: refs/heads/master Commit: 3a3ebc8485e82ea0cef84e5c4b3a7f076b0a8ea4 Parents: 2b8b20d Author: Pei He <pe...@google.com> Authored: Fri Sep 23 16:11:24 2016 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Fri Sep 23 16:46:08 2016 -0700 ---------------------------------------------------------------------- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 26 ++++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/3a3ebc84/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java index b8dcdc8..78a4c4f 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java @@ -502,7 +502,7 @@ public class BigQueryIOTest implements Serializable { public void testValidateReadSetsDefaultProject() throws Exception { String projectId = "someproject"; String datasetId = "somedataset"; - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject(projectId); bqOptions.setTempLocation("gs://testbucket/testdir"); @@ -528,9 +528,9 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(RunnableOnService.class) + @Category(NeedsRunner.class) public void testBuildSourceWithoutTableQueryOrValidation() { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation("gs://testbucket/testdir"); @@ -543,9 +543,9 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(RunnableOnService.class) + @Category(NeedsRunner.class) public void testBuildSourceWithTableAndQuery() { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation("gs://testbucket/testdir"); @@ -562,9 +562,9 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(RunnableOnService.class) + @Category(NeedsRunner.class) public void testBuildSourceWithTableAndFlatten() { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation("gs://testbucket/testdir"); @@ -581,9 +581,9 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(RunnableOnService.class) + @Category(NeedsRunner.class) public void testBuildSourceWithTableAndFlattenWithoutValidation() { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation("gs://testbucket/testdir"); @@ -603,7 +603,7 @@ public class BigQueryIOTest implements Serializable { @Test @Category(NeedsRunner.class) public void testReadFromTable() throws IOException { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation(testFolder.newFolder("BigQueryIOTest").getAbsolutePath()); @@ -638,7 +638,7 @@ public class BigQueryIOTest implements Serializable { @Test @Category(NeedsRunner.class) public void testWrite() throws Exception { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation(testFolder.newFolder("BigQueryIOTest").getAbsolutePath()); @@ -676,7 +676,7 @@ public class BigQueryIOTest implements Serializable { @Test @Category(NeedsRunner.class) public void testWriteUnknown() throws Exception { - BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); + BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); bqOptions.setTempLocation(testFolder.newFolder("BigQueryIOTest").getAbsolutePath()); @@ -833,7 +833,7 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(RunnableOnService.class) + @Category(NeedsRunner.class) public void testBuildWriteWithoutTable() { Pipeline p = TestPipeline.create(); thrown.expect(IllegalStateException.class);
