[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298921#comment-15298921
]
Tao Feng commented on SAMZA-949:
--------------------------------
Will fix for Samza-807 work for this?
> 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)
