You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by xinyuiscool <gi...@git.apache.org> on 2017/10/31 17:47:06 UTC

[GitHub] samza pull request #345: SAMZA-1477: Fix issues found by BEAM tests

GitHub user xinyuiscool opened a pull request:

    https://github.com/apache/samza/pull/345

    SAMZA-1477: Fix issues found by BEAM tests

    A bunch of issues were found by BEAM tests, which includes:
    
    1) WatermarkFunction needs to be able to return output after processWatermark()
    2) control message doesn't implement the equals() and hashcode()
    3) Some kafka system related code is not scala 2.10 compatible for tests.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/xinyuiscool/samza SAMZA-1477

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/samza/pull/345.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #345
    
----
commit 735f4b966b19521c3d7003c25209f5344f0fb6c3
Author: xiliu <xi...@xiliu-ld1.linkedin.biz>
Date:   2017-10-31T17:41:56Z

    SAMZA-1477: Fix issues found by BEAM tests

----


---

[GitHub] samza pull request #345: SAMZA-1477: Fix issues found by BEAM tests

Posted by asfgit <gi...@git.apache.org>.

Github user asfgit closed the pull request at:

    https://github.com/apache/samza/pull/345


---