flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2306) Add support for named streams in Storm compatibility layer
Date Fri, 14 Aug 2015 15:19:45 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14697200#comment-14697200
] 

ASF GitHub Bot commented on FLINK-2306:
---------------------------------------

Github user StephanEwen commented on the pull request:

    https://github.com/apache/flink/pull/1011#issuecomment-131144983
  
    Looks like an issue with shaded dependencies.
    
    Have a look here for some background on shading: https://cwiki.apache.org/confluence/display/FLINK/Hadoop+Versions+and+Dependency+Shading


> 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
>
> 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)

Mime
View raw message