You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/21 19:41:45 UTC

[jira] [Resolved] (FLINK-2306) Add support for named streams in Storm compatibility layer

     [ https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen resolved FLINK-2306.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 0.10

Implemented in 3a8302998d2fc7f38504c238916bc7d0dada2320

Thank you for the contribution!

> Add support for named streams in Storm compatibility layer
> ----------------------------------------------------------
>
>                 Key: FLINK-2306
>                 URL: https://issues.apache.org/jira/browse/FLINK-2306
>             Project: Flink
>          Issue Type: Improvement
>          Components: flink-contrib
>            Reporter: Matthias J. Sax
>            Assignee: Matthias J. Sax
>             Fix For: 0.10
>
>
> Currently, the layer only works on single stream and ignores stream names, ie, each stream is treated as "default" stream. The declaration of multiple output streams is ignored (all tuples are emitted to the same stream). If multiple input streams are consumed all tuples are merged into a single stream.
> This feature allows operators to declare multiple (named) output streams and emit tuples to different stream. Furthermore, it enables Bolts to distinguish incoming tuples from different streams by stream name (Storm tuple meta information).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)