[ https://issues.apache.org/jira/browse/FLINK-27128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709167#comment-17709167 ]
LiJun commented on FLINK-27128: ------------------------------- it is apparently a bug from my point of view. why is this issue pending there for almost one year? > Broadcast stream Iteration closeWith failed starting version 1.12.2 > ------------------------------------------------------------------- > > Key: FLINK-27128 > URL: https://issues.apache.org/jira/browse/FLINK-27128 > Project: Flink > Issue Type: Bug > Components: API / Core > Affects Versions: 1.12.2, 1.14.4 > Reporter: Jeff Hu > Priority: Major > Original Estimate: 1h > Remaining Estimate: 1h > > The following error on version later than 1.12.2: > "Cannot close an iteration with a feedback DataStream that does not originate > from said iteration." > There might be a bug with AbstractBroadcastStateTransformation.java. > possible fix: > predecessor.addAll(regularInput.getTransitivePredecessors()); > https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractBroadcastStateTransformation.java#L95 -- This message was sent by Atlassian Jira (v8.20.10#820010)