Skip to content

Commit a0f07fe

Browse files
authored
[FLINK-36402] edgeRemapings typo fixed to edgeRemappings
1 parent 506ac18 commit a0f07fe

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ private void visitIteration(
130130
ArrayNode jsonArray,
131131
List<Integer> toVisit,
132132
int headId,
133-
Map<Integer, Integer> edgeRemapings,
133+
Map<Integer, Integer> edgeRemappings,
134134
ArrayNode iterationInEdges) {
135135

136136
Integer vertexID = toVisit.get(0);
@@ -148,15 +148,15 @@ private void visitIteration(
148148
for (StreamEdge inEdge : vertex.getInEdges()) {
149149
int inputID = inEdge.getSourceId();
150150

151-
if (edgeRemapings.keySet().contains(inputID)) {
151+
if (edgeRemappings.keySet().contains(inputID)) {
152152
decorateEdge(inEdges, inEdge, inputID);
153153
} else if (!streamGraph.vertexIDtoLoopTimeout.containsKey(inputID)) {
154154
decorateEdge(iterationInEdges, inEdge, inputID);
155155
}
156156
}
157157

158-
edgeRemapings.put(vertexID, headId);
159-
visitIteration(jsonArray, toVisit, headId, edgeRemapings, iterationInEdges);
158+
edgeRemappings.put(vertexID, headId);
159+
visitIteration(jsonArray, toVisit, headId, edgeRemappings, iterationInEdges);
160160
}
161161
}
162162

0 commit comments

Comments
 (0)