You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2019/03/25 03:15:00 UTC

[jira] [Created] (SAMZA-2144) In TaskInstance, bypass "SSP caught-up" check if offset is set by a startpoint

Daniel Nishimura created SAMZA-2144:
---------------------------------------

             Summary: In TaskInstance, bypass "SSP caught-up" check if offset is set by a startpoint 
                 Key: SAMZA-2144
                 URL: https://issues.apache.org/jira/browse/SAMZA-2144
             Project: Samza
          Issue Type: Improvement
            Reporter: Daniel Nishimura
            Assignee: Daniel Nishimura
             Fix For: 1.1


TaskInstance maintains a "SSP caught-up map" to ensure that all tasks for the same SSP have caught up to he same checkpoint offset before processing any messages. However, this does not apply to startpoints since it expects to begin processing messages starting from the startpoint's offset position.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)