[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298927#comment-15298927
]
Yi Pan (Data Infrastructure) commented on SAMZA-949:
----------------------------------------------------
[~TaoFeng], it is related but different issue. This JIRA is tracking a more
general issue that deserialization or any non-recoverable failure in the
checkpoint topic should not be re-tried, while SAMZA-807 is *only* targeted to
deserialization errors caused by grouper class validation.
> 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)
