You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2017/09/12 21:19:53 UTC
[12/26] samza git commit: SAMZA-1400: disabling flaky test
testTwoStreamProcessors in TestZkStreamProcessorSession
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 <ha...@gmail.com>
Reviewers: Xinyu Liu <xi...@apache.org>
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/0.14.0
Commit: e21ff714637238e9fe1011a9f4f20699f1e9e471
Parents: afe3bf8
Author: Fred Ji <ha...@gmail.com>
Authored: Thu Aug 17 11:16:10 2017 -0700
Committer: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
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"});
}