[SAMZA-1340] StreamProcessor does not propagate container failures from StreamTask - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

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

Description

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.