Hi! My topology below seems to work when I comment out all the lines with ContinuousEventTimeTrigger, but prints nothing when the line is in there. Can I coGroup two large time windows that use a different trigger time than the window size? (even if the ContinuousEventTimeTrigger doesn't work for coGroups, I would not expect the result to be completely silent).
The streams I'm cogroupng are from 2 different Kafka sources and uses event time with 0 out of orderness and I'm on Flink 1.1.3, if that helps DataStream<CommonType> stream1 = <stream of event type1> .window(TumblingEventTimeWindows.of(Time.seconds(30))) .trigger(ContinuousEventTimeTrigger.of(Time.seconds(10))) .fold(...); DataStream<CommonType> stream2 = <stream of event type2> .window(TumblingEventTimeWindows.of(Time.seconds(30))) .trigger(ContinuousEventTimeTrigger.of(Time.seconds(10))) .fold(...); stream1.coGroup(stream2).where(...).equalTo(...) .window(TumblingEventTimeWindows.of(Time.seconds(30))) .trigger(ContinuousEventTimeTrigger.of(Time.seconds(10))) .print() Thanks, William