[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Branislav Cogic updated SAMZA-949:
----------------------------------
Attachment: SAMZA-949.0.patch
> 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
> Attachments: SAMZA-949.0.patch
>
>
> 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)
