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)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
