-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 0.13.1
-
Fix Version/s: 0.13.1
-
Component/s: None
-
Labels:None
Based on Chris Pettitt's observation:
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.
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.
- links to