Repository: samza Updated Branches: refs/heads/master 26dd9c14c -> 42c194040
SAMZA-1490: Fix TestRepartitionJoinWindowApp Author: Dong Lin <lindon...@gmail.com> Reviewers: Prateek Maheshwari <prate...@apache.org> Closes #356 from lindong28/SAMZA-1490 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/42c19404 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/42c19404 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/42c19404 Branch: refs/heads/master Commit: 42c194040c9adea29eddc92dc58ca01a59a22445 Parents: 26dd9c1 Author: Dong Lin <lindon...@gmail.com> Authored: Tue Nov 14 10:48:50 2017 -0800 Committer: Prateek Maheshwari <pmahe...@linkedin.com> Committed: Tue Nov 14 10:48:50 2017 -0800 ---------------------------------------------------------------------- .../test/operator/TestRepartitionJoinWindowApp.java | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/42c19404/samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java ---------------------------------------------------------------------- diff --git a/samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java b/samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java index 117f97b..49611bb 100644 --- a/samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java +++ b/samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java @@ -44,19 +44,16 @@ public class TestRepartitionJoinWindowApp extends StreamApplicationIntegrationTe // create events for the following user activity. // userId: (viewId, pageId, (adIds)) - // u1: (v1, p1, (a1, a2)), (v2, p2, (a3)) - // u2: (v3, p1, (a1, a2, a4)), (v4, p3, (a5)) + // u1: (v1, p1, (a1)), (v2, p2, (a3)) + // u2: (v3, p1, (a1)), (v4, p3, (a5)) produceMessage(PAGE_VIEWS, 0, "p1", "{\"viewId\":\"v1\",\"pageId\":\"p1\",\"userId\":\"u1\"}"); produceMessage(PAGE_VIEWS, 1, "p2", "{\"viewId\":\"v2\",\"pageId\":\"p2\",\"userId\":\"u1\"}"); produceMessage(PAGE_VIEWS, 0, "p1", "{\"viewId\":\"v3\",\"pageId\":\"p1\",\"userId\":\"u2\"}"); produceMessage(PAGE_VIEWS, 1, "p3", "{\"viewId\":\"v4\",\"pageId\":\"p3\",\"userId\":\"u2\"}"); produceMessage(AD_CLICKS, 0, "a1", "{\"viewId\":\"v1\",\"adId\":\"a1\"}"); - produceMessage(AD_CLICKS, 1, "a2", "{\"viewId\":\"v1\",\"adId\":\"a2\"}"); produceMessage(AD_CLICKS, 0, "a3", "{\"viewId\":\"v2\",\"adId\":\"a3\"}"); produceMessage(AD_CLICKS, 0, "a1", "{\"viewId\":\"v3\",\"adId\":\"a1\"}"); - produceMessage(AD_CLICKS, 1, "a2", "{\"viewId\":\"v3\",\"adId\":\"a2\"}"); - produceMessage(AD_CLICKS, 1, "a4", "{\"viewId\":\"v3\",\"adId\":\"a4\"}"); produceMessage(AD_CLICKS, 0, "a5", "{\"viewId\":\"v4\",\"adId\":\"a5\"}"); // run the application @@ -71,11 +68,7 @@ public class TestRepartitionJoinWindowApp extends StreamApplicationIntegrationTe String key = message.key(); String value = message.value(); Assert.assertTrue(key.equals("u1") || key.equals("u2")); - if ("u1".equals(key)) { - Assert.assertEquals("3", value); - } else { - Assert.assertEquals("4", value); - } + Assert.assertEquals("2", value); } } }
