dxichen commented on a change in pull request #1483:
URL: https://github.com/apache/samza/pull/1483#discussion_r603649068
##########
File path:
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java
##########
@@ -146,6 +147,13 @@ public final void processAsync(IncomingMessageEnvelope
ime, MessageCollector col
callback.complete();
}
});
+ } else {
+ // If InputOperator is not found in the operator graph for a given
SystemStream, throw an exception else the
+ // job will timeout due to async task callback timeout
(TaskCallbackTimeoutException)
+ final String errMessage = String.format("InputOperator not found in
OperatorGraph for %s. Please check SystemStream "
Review comment:
It would be helpful for debugging this in the case that the hash is
different to log all available input operators to easily identify the mismatch
using `operatorImplGraph#getAllInputOperators`
--
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]
