sujay-jain commented on code in PR #25576:
URL: https://github.com/apache/flink/pull/25576#discussion_r1947934751
##########
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##########
@@ -1191,6 +1191,12 @@ public static void setOperatorConfig(
? 0 // single input operator
: inEdge.getTypeNumber() - 1; // in case of 2 or
more inputs
+ Preconditions.checkState(
+ inputIndex < inputSerializers.length,
+ "Input type serializer of vertex '%s' was null or
undefined for inputIndex %s",
Review Comment:
Consider making the error message more descriptive by adding some more
context. For example, specifying the expected number of input serializers can
help with debugging. A possible improvement could be:
`"Invalid inputIndex %s for vertex '%s': Expected inputIndex to be less than
%s (number of input serializers)."`
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
