[
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 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]
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.
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 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]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
