Repository: samza Updated Branches: refs/heads/master afe3bf861 -> e21ff7146
SAMZA-1400: disabling flaky test testTwoStreamProcessors in TestZkStreamProcessorSession In this SAMZA-1400, We are disabling this flaky one in master and will cherry pick for 0.13.1. We have created a ticket SAMZA-1399 for fixing it in later build. navina sborya Please take a look. Author: Fred Ji <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #278 from fredji97/SAMZA1400 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/e21ff714 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/e21ff714 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/e21ff714 Branch: refs/heads/master Commit: e21ff714637238e9fe1011a9f4f20699f1e9e471 Parents: afe3bf8 Author: Fred Ji <[email protected]> Authored: Thu Aug 17 11:16:10 2017 -0700 Committer: Xinyu Liu <[email protected]> Committed: Thu Aug 17 11:16:10 2017 -0700 ---------------------------------------------------------------------- .../org/apache/samza/processor/TestZkStreamProcessorSession.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/e21ff714/samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java ---------------------------------------------------------------------- diff --git a/samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java b/samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java index 6aab5e3..880d766 100644 --- a/samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java +++ b/samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java @@ -43,7 +43,8 @@ public class TestZkStreamProcessorSession extends TestZkStreamProcessorBase { testStreamProcessorWithSessionRestart(new String[]{"1"}); } - @Test + // TODO: SAMZA-1399 fix the flaky test testTwoStreamProcessors and re-enable it + // @Test public void testTwoStreamProcessors() { testStreamProcessorWithSessionRestart(new String[]{"2", "3"}); }
