Ajo Thomas created SAMZA-2641:
---------------------------------
Summary: Do not silently fail when InputOperator is not found in
Operator graph
Key: SAMZA-2641
URL: https://issues.apache.org/jira/browse/SAMZA-2641
Project: Samza
Issue Type: Bug
Reporter: Ajo Thomas
Assignee: Ajo Thomas
If InputOperator is not found in OperatorGraph during pipeline processing, the
pipeline would silently fail and the job will eventually timeout due to async
task callback timeout.
We need to throw and error instead.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)