[FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConf…

…ig checks input serializer lengh
liuml07 · Oct 26, 2024 · a718894 · a718894
1 parent 20e9826
commit a718894
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...untime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/...untime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
@@ -1094,6 +1094,12 @@ private 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",
+                    vertex,
+                    inputIndex);
+
             if (chainedSource != null) {
                 // chained source is the input
                 if (inputConfigs[inputIndex] != null) {