Hi, You’re absolutely right. I created an Issue for this: https://issues.apache.org/jira/browse/FLINK-6246
Best, Aljoscha > On 3. Apr 2017, at 10:22, Dawid Wysakowicz <wysakowicz.da...@gmail.com> wrote: > > Hi, > I am implementing emitting discarded patterns in CEP library through Side > Outputs and I have a question about the Output::collect method which is: > > <X> void collect(OutputTag<?> outputTag, StreamRecord<X> record); > > Why the type of the outputTag is not also X? Or at least T extends X? > > Thanks in advance for some info on it. > > Regards > Dawid Wysakowicz