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

Posted to commits@samza.apache.org by "Branislav Cogic (JIRA)" <ji...@apache.org> on 2016/05/24 10:42:12 UTC

[jira] [Assigned] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

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

Branislav Cogic reassigned SAMZA-949:
-------------------------------------

    Assignee: Branislav Cogic

> KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures
> -----------------------------------------------------------------------------------------------------
>
>                 Key: SAMZA-949
>                 URL: https://issues.apache.org/jira/browse/SAMZA-949
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Yi Pan (Data Infrastructure)
>            Assignee: Branislav Cogic
>
> Currently, KafkaCheckpointManager retries forever, if there is a deserialization error from checkpoint topic. One example is that the deserialization failed due to validation of the "same" grouper factory is used in between two job runs. We should differentiate the non-recoverable case and error out here.



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