gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <j...@apache.org>
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
                 URL: https://issues.apache.org/jira/browse/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
scenario,

1. Output minClock is set to Long.MaxValue since all messages have been acked by downstream
tasks
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
(v6.4.14#64029)

Mime
View raw message