Hi all, I am trying to implement an iterative streaming job that processes the loop with a KeyedProcessFunction.
I need a KeyedProcessFunction to use keyed state and to emit a side-output (that after further transformations becomes the feedback) Problem is IterativeStream.process() only accepts ProcessFunction, no KeyedProcessFunction. The main and feedback streams have the same payload type, and I am keying both before starting and closing the iteration. I understand I cannot re-key after starting the iteration, as IterativeStream does not support keyBy() and throws an UnsupportedOperationException "Cannot change the input partitioning of an iteration head directly. Apply the partitioning on the input and feedback streams instead." Is there any way of using keyed state within an iteration? BTW, I am using Flink 1.15.2 and I am bound to that version Regards Lorenzo
