You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/07/06 17:20:39 UTC
[33/50] [abbrv] incubator-beam git commit: KafkaIO tests : change
category annotation from RunnableOnService to NeedsRunner
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 <ra...@google.com>
Authored: Thu Jun 30 10:51:35 2016 -0700
Committer: Luke Cwik <lc...@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;