[GEARPUMP-370] clock does not seem to advance for stateful sources

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.8.5
• Component/s: core, streaming
• Environment: Distributed - SLES(Linux)
• Assignee: Unassigned
• Reporter: Hashan Gayasri Udugahapattuwa
• Created: 04/Apr/18 12:28
• Updated: 04/Apr/18 12:28

Description

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.