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();

Reply via email to