Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-889

Change log not working properly with In memory Store

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.1
    • None
    • None

    Description

      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.

      Attachments

        1. SAMZA-889-0.patch
          51 kB
          Navina Ramesh
        2. SAMZA-889-1.patch
          74 kB
          Yi Pan

        Activity

          People

            navina Navina Ramesh
            snoghabi Shadi A. Noghabi
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: