[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289914#comment-14289914
]
ASF GitHub Bot commented on FLINK-1381:
---------------------------------------
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/332#issuecomment-71260370
Hey!
Thank you for the effort, it looks good. Unfortunately I have recently
pushed the commits that allow operator chaining and I totally reworked the
jobgraphbuilder and the output collectors.
So basically we need to move around some of the code that you have written.
The jobgraphbuilder part will go into the StreamGraph and the
StreamingJobGraphGenerator. The DirectedStreamCollector part will go to the
DirectedCollectorWrapper.
Its not a big deal, I will fix your commit on monday if that is okay for
you , so you dont need to dig yourself through the new changes if you dont
want. (by keeping you author of the commit of course)
> Only one output splitter supported per operator
> -----------------------------------------------
>
> Key: FLINK-1381
> URL: https://issues.apache.org/jira/browse/FLINK-1381
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 0.9
> Reporter: Gyula Fora
> Assignee: Mingliang Qi
> Priority: Minor
>
> Currently the streaming api only supports output splitting once per operator.
> The splitting logic should be reworked to allow any number of it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
