You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by John Tipper <jo...@hotmail.com> on 2019/06/17 10:18:34 UTC

What order are events processed in iterative loop?

For the case of a single iteration of an iterative loop where the feedback type is different to the input stream type, what order are events processed in the forward flow? So for example, if we have:

  *   the input stream contains input1 followed by input2
  *   a ConnectedIterativeStream<input, feedback> at the head of an iteration
  *   followed by a CoProcessFunction, which emits a feedback element in response to an inputthat closes the ConnectedIterativeStream

For an input stream of input1 followed by input2, what order of events does the CoProcessFunction see?

Does it see "input1, feedback1, input2, feedback2", or "input1, input2, feedback1, feedback2", or is it a non-deterministic processing time order based on the execution time of the CoProcessFunction, but where input1 is always processed before input2 and feedback1 is always processed before feedback2, e.g. either of the two orders are possible?

Many thanks,

John