gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <>
Subject [jira] [Created] (GEARPUMP-317) Task minClock could be non increasing
Date Mon, 12 Jun 2017 22:09:00 GMT
Manu Zhang created GEARPUMP-317:

             Summary: Task minClock could be non increasing
                 Key: GEARPUMP-317
             Project: Apache Gearpump
          Issue Type: Bug
          Components: streaming
    Affects Versions: 0.8.3
            Reporter: Manu Zhang
            Assignee: Manu Zhang

Task minClock is the minimum of upstream minClock and output minCloc. Considering the following

1. Output minClock is set to Long.MaxValue since all messages have been acked by downstream
2. But there are messages buffered in a window function
3. Later the window is triggered and those messages are emitted, which will set the output
minClock to a smaller value.
4. Plus, the output messages are possibly not in time order, which again will make output
minClock non increasing.

This message was sent by Atlassian JIRA

View raw message