[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (GEARPUMP-370) clock does not seem to advance for stateful sources

Hashan Gayasri Udugahapattuwa created GEARPUMP-370:

             Summary: clock does not seem to advance for stateful sources
                 Key: GEARPUMP-370
                 URL: https://issues.apache.org/jira/browse/GEARPUMP-370
             Project: Apache Gearpump
          Issue Type: Bug
          Components: core, streaming
    Affects Versions: 0.8.5
         Environment: Distributed - SLES(Linux)
            Reporter: Hashan Gayasri Udugahapattuwa
         Attachments: logs.tar.xz, org.apache.gearpump.streaming.examples.state.tar.xz, org.apache.gearpump.streaming.examples.statefuldummytest.tar.xz

Clock does not seem to advance for _stateful_ sources even after the fix for 0.8.4 (but it was successful in fixing the clock issue in _stateless_ applications). 

Even if the "state" example uses a counter starting from EPOCH as the timestamp, the clock doesn't seem to advance. 

Recreatable with attached:
 * State example with HBase dependency replaced with Kafka
 * An SOL type *stateful* custom example with configurable pipeline stages and parallelism. Implements the TimeReplayableSource API.

This message was sent by Atlassian JIRA