Re: SideOutput Issue

We were able to reproduce the issue. It was caused by calling getSideOutput() and split() on a single DataStream, which isn't properly handled by Flink. As a work-around one can add a no-op map function before the split() call. I've filed FLINK-9141

Re: SideOutput Issue

Hi, which version of Flink are you using? Could you provide us with a reproducing example? I tried reproducing it based on the information you provided in the following code, but it runs fine for me: private static final OutputTag tag = new OutputTag("test"){}; public static void

SideOutput Issue

Hi All, I'm having issues with creating side outputs. There are two input sources (both from kafka) and they are connected and fed into a co-process function. Inside the co-process, the regular data stream outputs a POJO and in processElement2 there is a periodic timer which creates the side outpu