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 (v7.6.3#76005)