[jira] [Created] (SAMZA-329) AM should read checkpoints and provide them to containers

["Jakob Homan (JIRA)" <ji...@apache.org>]

Jakob Homan created SAMZA-329:
---------------------------------

             Summary: AM should read checkpoints and provide them to containers
                 Key: SAMZA-329
                 URL: https://issues.apache.org/jira/browse/SAMZA-329
             Project: Samza
          Issue Type: Improvement
          Components: kafka
            Reporter: Jakob Homan


Currently each container reads its checkpoint partition to find the latest offsets.  Post SAMZA-123, the checkpoints are written into a single-partition topic that each container reads through, discarding those checkpoints for which it does not have SSPs.  It would be better if the AM were to read the checkpoint once and pass the offset to the container as part of the input stream definition.



--
This message was sent by Atlassian JIRA
(v6.2#6252)