You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Navina Ramesh (JIRA)" <ji...@apache.org> on 2016/03/17 21:59:33 UTC

[jira] [Assigned] (SAMZA-889) Change log not working properly with In memory Store

     [ https://issues.apache.org/jira/browse/SAMZA-889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Navina Ramesh reassigned SAMZA-889:
-----------------------------------

    Assignee: Navina Ramesh

> Change log not working properly with In memory Store
> ----------------------------------------------------
>
>                 Key: SAMZA-889
>                 URL: https://issues.apache.org/jira/browse/SAMZA-889
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Shadi A. Noghabi
>            Assignee: Navina Ramesh
>
> Changle log does not work correctly with InMemory store. If you kill a job and start it again, it will not read from the beginning of the change log and bootstrap the state. Instead it will read from the newest offset. 
> The reason for this bug is that the OFFSET file will be created even if the RocksDB store is not used. When a job is restated it checks if an OFFSET file exist, and if it does it will use those offsets as the offset to read from the change log. However, for an InMemory store, the state has to be rebuilt form the beginning since there is not snapshot on the disk, even though the OFFSET file is there.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)