Repository: beam Updated Branches: refs/heads/master ed40093d8 -> fb41b2950
Minor cleanup. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b8abfba Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b8abfba Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b8abfba Branch: refs/heads/master Commit: 1b8abfba39e1c820255dd4436d14e4057407f738 Parents: 9bd5e6f Author: Robert Bradshaw <rober...@gmail.com> Authored: Mon Nov 20 12:34:40 2017 -0800 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Tue Nov 21 09:57:29 2017 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/runners/PipelineRunnerTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/1b8abfba/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/PipelineRunnerTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/PipelineRunnerTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/PipelineRunnerTest.java index e7cca28..94c77ae 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/PipelineRunnerTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/PipelineRunnerTest.java @@ -31,8 +31,8 @@ import org.apache.beam.sdk.metrics.MetricsFilter; import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.options.PipelineOptionsFactory; import org.apache.beam.sdk.testing.CrashingRunner; +import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; -import org.apache.beam.sdk.testing.ValidatesRunner; import org.apache.beam.sdk.transforms.Create; import org.apache.beam.sdk.transforms.MapElements; import org.apache.beam.sdk.transforms.PTransform; @@ -77,7 +77,7 @@ public class PipelineRunnerTest { } @Test - @Category(ValidatesRunner.class) + @Category(NeedsRunner.class) public void testRunPTransform() { final String namespace = PipelineRunnerTest.class.getName(); final Counter counter = Metrics.counter(namespace, "count"); @@ -94,6 +94,7 @@ public class PipelineRunnerTest { } ); + // Checking counters to verify the pipeline actually ran. assertThat( result.metrics().queryMetrics( MetricsFilter.builder()
