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)

Reply via email to