Yi Pan (Data Infrastructure) created SAMZA-949:
--------------------------------------------------
Summary: 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)
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)
