Zhipeng Zhang created FLINK-31160: ------------------------------------- Summary: Support join/cogroup in BroadcastUtils.withBroadcastStream Key: FLINK-31160 URL: https://issues.apache.org/jira/browse/FLINK-31160 Project: Flink Issue Type: Improvement Components: Library / Machine Learning Affects Versions: ml-2.1.0, ml-2.0.0, ml-2.2.0 Reporter: Zhipeng Zhang Fix For: ml-2.2.0
Currently BroadcastUtils#withBroadcastStream does not support cogroup/join, since we restricted that users can only introduce one extra operator in the specified lambda function. To support using join/cogroup in BroadcastUtils#withBroadcastStream, we would like to relax the restriction such that users can introduce more than more extra operator, but only the output operator can access the broadcast variables. -- This message was sent by Atlassian Jira (v8.20.10#820010)