beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [33/50] [abbrv] incubator-beam git commit: KafkaIO tests : change category annotation from RunnableOnService to NeedsRunner
Date Wed, 06 Jul 2016 17:20:39 GMT
KafkaIO tests : change category annotation from RunnableOnService to NeedsRunner


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ed32d10e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ed32d10e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ed32d10e

Branch: refs/heads/runners-spark2
Commit: ed32d10e6474a64dd17280f0f755d6eb03c3a21b
Parents: 9a17d49
Author: Raghu Angadi <rangadi@google.com>
Authored: Thu Jun 30 10:51:35 2016 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Wed Jul 6 10:18:52 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/ed32d10e/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
index 7d4337d..587e3e2 100644
--- a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
+++ b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
@@ -29,8 +29,8 @@ import org.apache.beam.sdk.io.Read;
 import org.apache.beam.sdk.io.UnboundedSource;
 import org.apache.beam.sdk.io.UnboundedSource.UnboundedReader;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;
+import org.apache.beam.sdk.testing.NeedsRunner;
 import org.apache.beam.sdk.testing.PAssert;
-import org.apache.beam.sdk.testing.RunnableOnService;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Count;
 import org.apache.beam.sdk.transforms.DoFn;
@@ -237,7 +237,7 @@ public class KafkaIOTest {
   }
 
   @Test
-  @Category(RunnableOnService.class)
+  @Category(NeedsRunner.class)
   public void testUnboundedSource() {
     Pipeline p = TestPipeline.create();
     int numElements = 1000;
@@ -252,7 +252,7 @@ public class KafkaIOTest {
   }
 
   @Test
-  @Category(RunnableOnService.class)
+  @Category(NeedsRunner.class)
   public void testUnboundedSourceWithExplicitPartitions() {
     Pipeline p = TestPipeline.create();
     int numElements = 1000;
@@ -290,7 +290,7 @@ public class KafkaIOTest {
   }
 
   @Test
-  @Category(RunnableOnService.class)
+  @Category(NeedsRunner.class)
   public void testUnboundedSourceTimestamps() {
     Pipeline p = TestPipeline.create();
     int numElements = 1000;
@@ -318,7 +318,7 @@ public class KafkaIOTest {
   }
 
   @Test
-  @Category(RunnableOnService.class)
+  @Category(NeedsRunner.class)
   public void testUnboundedSourceSplits() throws Exception {
     Pipeline p = TestPipeline.create();
     int numElements = 1000;


Mime
View raw message