Yun Gao created FLINK-24646: ------------------------------- Summary: Add operator wrapper for all-round iterations Key: FLINK-24646 URL: https://issues.apache.org/jira/browse/FLINK-24646 Project: Flink Issue Type: Sub-task Components: Library / Machine Learning Reporter: Yun Gao Assignee: Yun Gao Fix For: 0.1.0
Inside the iteration, we will also broadcast the special events to mark the end of rounds. To process these events, all the operators inside the iteration is wrapped with a specialized wrapper operator. There are two kinds of wrappers: the first wrapper would not recreate the users' operator for each round, and the second one would. This issue would implement the first kind. -- This message was sent by Atlassian Jira (v8.3.4#803005)