You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/07/01 04:27:28 UTC
[1/2] incubator-beam git commit: KafkaIO tests : change category
annotation from RunnableOnService to NeedsRunner
Repository: incubator-beam
Updated Branches:
refs/heads/master 75089c4d2 -> e7418e2e8
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/cbcb353d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cbcb353d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cbcb353d
Branch: refs/heads/master
Commit: cbcb353d4a4afff2bf87bc9789d1aa0a40ee258b
Parents: 75089c4
Author: Raghu Angadi <ra...@google.com>
Authored: Thu Jun 30 10:51:35 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Jun 30 21:26:59 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/cbcb353d/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;
[2/2] incubator-beam git commit: Closes #568 and closes #524
Posted by dh...@apache.org.
Closes #568 and closes #524
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e7418e2e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e7418e2e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e7418e2e
Branch: refs/heads/master
Commit: e7418e2e8ab8b138cc36ad37e1372e24919f021b
Parents: 75089c4 cbcb353
Author: Dan Halperin <dh...@google.com>
Authored: Thu Jun 30 21:26:59 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Jun 30 21:27:07 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------