GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/234
[GEARPUMP-359] Fix OutputWatermark advancing logic in Subscription
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Mak
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/234#discussion_r147105502
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/Subscription.scala
---
@@ -209,7 +202,8 @@ class Subscription(
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/234
---
