SplittableParDoTest does not require RunnableOnService
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7f5542e0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7f5542e0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7f5542e0 Branch: refs/heads/master Commit: 7f5542e0cf21e21822e5a2ee91ed872c1824a4bf Parents: ecc2abf Author: Kenneth Knowles <k...@google.com> Authored: Mon Oct 17 15:51:11 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue Oct 18 09:18:14 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/core/SplittableParDoTest.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7f5542e0/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java index b7cdc64..29ff838 100644 --- a/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java +++ b/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java @@ -34,7 +34,6 @@ import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.coders.BigEndianIntegerCoder; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.coders.SerializableCoder; -import org.apache.beam.sdk.testing.RunnableOnService; import org.apache.beam.sdk.testing.TestPipeline; import org.apache.beam.sdk.transforms.Create; import org.apache.beam.sdk.transforms.DoFn; @@ -53,7 +52,6 @@ import org.apache.beam.sdk.values.TimestampedValue; import org.joda.time.Duration; import org.joda.time.Instant; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -123,7 +121,6 @@ public class SplittableParDoTest { } @Test - @Category(RunnableOnService.class) public void testBoundednessForBoundedFn() { Pipeline pipeline = TestPipeline.create(); DoFn<Integer, String> boundedFn = new BoundedFakeFn(); @@ -142,7 +139,6 @@ public class SplittableParDoTest { } @Test - @Category(RunnableOnService.class) public void testBoundednessForUnboundedFn() { Pipeline pipeline = TestPipeline.create(); DoFn<Integer, String> unboundedFn = new UnboundedFakeFn();