Kostas Kloudas created FLINK-6538: ------------------------------------- Summary: Emit late elements as Side Outputs Key: FLINK-6538 URL: https://issues.apache.org/jira/browse/FLINK-6538 Project: Flink Issue Type: Improvement Components: CEP Affects Versions: 1.3.0 Reporter: Kostas Kloudas Fix For: 1.3.0
Currently in the {{select/flatSelect}} there is a {{map/flatMap}} after the returned stream. These should go inside the {{CEPOperator}} so that we are allowed to call {{getSideOutput}} directly on the returned stream. -- This message was sent by Atlassian JIRA (v6.3.15#6346)