[
https://issues.apache.org/jira/browse/SAMZA-1084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1084:
---------------------------------
Description: The current user model for StreamProcessor API allows the user
to start (asynchronous) and stop processor. awaitStart allows the user to wait
until the processor actually initializes and starts processing messages.
However, in case the processor fails during processing or prior to processing,
the error is not propagated to the user context. There is also no way for the
user to continuously check the status of the processor. Without these
abilities, it is very hard to troubleshoot and take action on error.
> User thread does not see errors from the processor thread when using the
> StreamProcessor API
> --------------------------------------------------------------------------------------------
>
> Key: SAMZA-1084
> URL: https://issues.apache.org/jira/browse/SAMZA-1084
> Project: Samza
> Issue Type: Bug
> Reporter: Navina Ramesh
> Assignee: Navina Ramesh
> Fix For: 0.13.0
>
>
> The current user model for StreamProcessor API allows the user to start
> (asynchronous) and stop processor. awaitStart allows the user to wait until
> the processor actually initializes and starts processing messages. However,
> in case the processor fails during processing or prior to processing, the
> error is not propagated to the user context. There is also no way for the
> user to continuously check the status of the processor. Without these
> abilities, it is very hard to troubleshoot and take action on error.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
