Huafeng Wang created GEARPUMP-359:
-------------------------------------
Summary: The premature OutputWatermark advancing logic in
Subscription is not right
Key: GEARPUMP-359
URL: https://issues.apache.org/jira/browse/GEARPUMP-359
Project: Apache Gearpump
Issue Type: Bug
Reporter: Huafeng Wang
Assignee: Huafeng Wang
{{Subscription}} will update processingWatermark when sending a message and
update outputWatermark when receiving an Ack message. It will cause prematurely
updating the outputWatermark in such scenario: the {{Subscription}} already
sent 200 messages to downstream and now the processingWatermark is 200th
message's watermark, then it receives the first 100 messages' Ack and it will
advance the outputWatermark to 200th message's watermark, not the 100th one,
which is wrong.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)