[
https://issues.apache.org/jira/browse/SAMZA-1340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066972#comment-16066972
]
ASF GitHub Bot commented on SAMZA-1340:
---------------------------------------
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/230
> StreamProcessor does not propagate container failures from StreamTask
> ---------------------------------------------------------------------
>
> Key: SAMZA-1340
> URL: https://issues.apache.org/jira/browse/SAMZA-1340
> Project: Samza
> Issue Type: Bug
> Affects Versions: 0.131
> Reporter: Navina Ramesh
> Assignee: Navina Ramesh
> Fix For: 0.13.1
>
>
> Based on [~cpettitt]'s observation:
> bq. I'm on Samza's master branch. If my task throws from one of its operators
> I get back a success state from the LocalApplicationRunner.
> bq. The root cause appears to be in SamzaContainerListener#onContainerFailed
> in StreamProcessor. There we call a regular stop and have not recorded
> anywhere that an exception was raised. Consequently onCoordinatorStop is
> invoked and the processorListener gets its onShutdown callback called instead
> of onFailure via onCoordinatorFailure.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
