[ https://issues.apache.org/jira/browse/APEXMALHAR-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319332#comment-15319332 ]
ASF GitHub Bot commented on APEXMALHAR-2106: -------------------------------------------- Github user bhupeshchawda commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/309#discussion_r66146875 --- Diff: library/src/main/java/com/datatorrent/lib/stream/StreamMerger.java --- @@ -59,6 +61,7 @@ public void process(K tuple) /** * Data input port 2. */ + @InputPortFieldAnnotation(optional = true) --- End diff -- Same here > Support merging multiple streams with StreamMerger > --------------------------------------------------- > > Key: APEXMALHAR-2106 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2106 > Project: Apache Apex Malhar > Issue Type: New Feature > Reporter: Ilya Ganelin > Assignee: Ilya Ganelin > > To properly implement the Flatten transformation (and other Stream > combination operations), Apex must support merging data from multiple > sources. The StreamMerger operator can be improved to merge multiple streams, > rather than just the two streams it can handle in the present implementation. -- This message was sent by Atlassian JIRA (v6.3.4#6332)