gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hashan Gayasri Udugahapattuwa (JIRA)" <>
Subject [jira] [Created] (GEARPUMP-370) clock does not seem to advance for stateful sources
Date Wed, 04 Apr 2018 12:29:00 GMT
Hashan Gayasri Udugahapattuwa created GEARPUMP-370:

             Summary: clock does not seem to advance for stateful sources
                 Key: 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

View raw message