GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/415
SAMZA-1578: Fix watermark bug found by BEAM tests
The problem is getOutputWatermark() does not return the real
outputWatermark. This caused problem in user override watermark function.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xinyuiscool/samza SAMZA-1578
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/415.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 #415
----
commit 392e483b08267257ff7d75a2441e8b5bc9f214a6
Author: xiliu <xiliu@...>
Date: 2018-01-26T21:09:10Z
SAMZA-1578: Fix watermark bug found by BEAM tests
----
---
