Repository: samza Updated Branches: refs/heads/master ed8dad54b -> ea2b6fa91
SAMZA-1538: Disabled Flaky Tests in TestStreamProcessor Author: Prateek Maheshwari <[email protected]> Reviewers: Shanthoosh Venkataraman <[email protected]> Closes #389 from prateekm/disable-flaky-test Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/ea2b6fa9 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/ea2b6fa9 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/ea2b6fa9 Branch: refs/heads/master Commit: ea2b6fa915473e2f120a4860c32cd09b4516c283 Parents: ed8dad5 Author: Prateek Maheshwari <[email protected]> Authored: Mon Dec 18 16:45:06 2017 -0800 Committer: Prateek Maheshwari <[email protected]> Committed: Mon Dec 18 16:45:06 2017 -0800 ---------------------------------------------------------------------- .../apache/samza/test/processor/TestStreamProcessor.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/ea2b6fa9/samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java ---------------------------------------------------------------------- diff --git a/samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java b/samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java index c37132f..a44265a 100644 --- a/samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java +++ b/samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java @@ -67,7 +67,8 @@ public class TestStreamProcessor extends StandaloneIntegrationTestHarness { * The standalone version in this test uses KafkaSystemFactory and it uses a SingleContainerGrouperFactory. Hence, * no matter how many tasks are present, it will always be run in a single processor instance. This simplifies testing */ - @Test +// TODO Fix in SAMZA-1538 +// @Test public void testStreamProcessor() { final String testSystem = "test-system"; final String inputTopic = "numbers"; @@ -88,7 +89,8 @@ public class TestStreamProcessor extends StandaloneIntegrationTestHarness { /** * Should be able to create task instances from the provided task factory. */ - @Test +// TODO Fix in SAMZA-1538 +// @Test public void testStreamProcessorWithStreamTaskFactory() { final String testSystem = "test-system"; final String inputTopic = "numbers2"; @@ -107,7 +109,8 @@ public class TestStreamProcessor extends StandaloneIntegrationTestHarness { /** * Should be able to create task instances from the provided task factory. */ - @Test +// TODO Fix in SAMZA-1538 +// @Test public void testStreamProcessorWithAsyncStreamTaskFactory() { final String testSystem = "test-system"; final String inputTopic = "numbers3";
