[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lijie Wang closed FLINK-27800. ------------------------------ Resolution: Fixed > addInEdge check state error > --------------------------- > > Key: FLINK-27800 > URL: https://issues.apache.org/jira/browse/FLINK-27800 > Project: Flink > Issue Type: Bug > Components: API / Core > Affects Versions: 1.17.0, 1.15.3, 1.16.1 > Reporter: Licho Sun > Priority: Major > Labels: pull-request-available > Fix For: 1.17.0, 1.15.4, 1.16.2 > > > when add InEdge, the checkState fucntion check the edge whether is in > outEdges list, this should check whether in inEdges list. > > {code:java} > public void addInEdge(StreamEdge inEdge) { > checkState( > outEdges.stream().noneMatch(inEdge::equals), > "Adding not unique edge = %s to existing outEdges = %s", > inEdge, > inEdges); > if (inEdge.getTargetId() != getId()) { > throw new IllegalArgumentException("Destination id doesn't match the > StreamNode id"); > } else { > inEdges.add(inEdge); > } > } {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)