[
https://issues.apache.org/jira/browse/SAMZA-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ajo Thomas updated SAMZA-2641:
------------------------------
Description:
If InputOperator is not found in OperatorGraph for a SystenStream,the pipeline
would silently fail and the job will eventually timeout due to async task
callback timeout ({{TaskCallbackTimeoutException}}).
We need to throw and error instead.
[https://github.com/apache/samza/blob/a2827db501afc98d420ada50cf7a914436b8dd66/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java#L117]
was:
If InputOperator is not found in OperatorGraph during pipeline processing
(StreamOperatorTask), the pipeline would silently fail and the job will
eventually timeout due to async task callback timeout
({{TaskCallbackTimeoutException}}).
We need to throw and error instead.
[https://github.com/apache/samza/blob/a2827db501afc98d420ada50cf7a914436b8dd66/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java#L117]
> Do not silently fail when InputOperator is not found in OperatorGraph
> ---------------------------------------------------------------------
>
> Key: SAMZA-2641
> URL: https://issues.apache.org/jira/browse/SAMZA-2641
> Project: Samza
> Issue Type: Bug
> Reporter: Ajo Thomas
> Assignee: Ajo Thomas
> Priority: Minor
>
> If InputOperator is not found in OperatorGraph for a SystenStream,the
> pipeline would silently fail and the job will eventually timeout due to async
> task callback timeout ({{TaskCallbackTimeoutException}}).
> We need to throw and error instead.
> [https://github.com/apache/samza/blob/a2827db501afc98d420ada50cf7a914436b8dd66/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java#L117]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
