ajothomas opened a new pull request #1483:
URL: https://github.com/apache/samza/pull/1483
**Symptom**:
Samza job fails with a TaskCallbackTimeoutException if InputOperator is not
found in OperatorGraph for a SystemStream
**Cause:**
Currently, the pipeline silently fails when there is no InputOperator for a
SystemStream in the OperatorGraph as the code doesn't handle such cases. The
pipeline just silently fails and the job would throw an exception due to sync
task callback timeout (TaskCallbackTimeoutException).
**Changes:**
Call `failure` method of the TaskCallback with a SamzaException with the
appropriate exception message.
**Tests:**
Adding a unit test in TestStreamOperatorTask class to check if the
appropriate exception was thrown for the use case discussed above.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
