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)
