Re: Joining two streams of different priorities

Hi, This is not possible with Flink. Events in transport channels cannot be reordered and function cannot pick which input to read from. There are some upcoming changes for the unified batch-stream integration that enable to chose which input to read from, but this is not there yet, AFAIK. Best,

Joining two streams of different priorities

My main input stream (inputStream1) gets processed using a pipeline that looks like below inputStream1 .keyBy("some-key") .window(TumblingEventTimeWindows.of(Time.seconds(Properties.WINDOW_SIZE)))