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

Posted to dev@samza.apache.org by GitBox <gi...@apache.org> on 2019/03/25 04:15:14 UTC

[GitHub] [samza] dnishimura opened a new pull request #971: SAMZA-2144: In TaskInstance, bypass "SSP caught-up" check if offset is set by a startpoint

dnishimura opened a new pull request #971: SAMZA-2144: In TaskInstance, bypass "SSP caught-up" check if offset is set by a startpoint
URL: https://github.com/apache/samza/pull/971
 
 
   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.
   
   @shanthoosh please take a look.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services