Re: Flink runner. Optimization for sideOutput with tags

I'm having a look at your PRs now. I think the change is good, and it's actually quite simple too. Thanks for looking into this! On Mon, 5 Dec 2016 at 05:48 Alexey Demin wrote: > Aljoscha > > I mistaken with flink runtime =) > > What do you think about some modification

Re: Flink runner. Optimization for sideOutput with tags

Aljoscha I mistaken with flink runtime =) What do you think about some modification FlinkStreamingTransformTransla tors: move split out of for-loop: SplitStream splitStream = unionOutputStream.split(new OutputSelector() { @Override public Iterable select(RawUnionValue value) {