Hi All,
As per my knowledge, all windowing operators in flink are
stateful. So let's say I have 2 streams, Stream1 and Stream2.
Stream1 and Stream2 are aggregated over some key and which is then windowed
on EventTime. So record X from Stream1 reaches flink on time, however,
record X' from Stream2 reaches after maxOutOfOrderness time has passed. In
this scenario as per my knowledge. X will be maintained in the flink state.
However, when X' comes, how do I do a lookup for X from the flink state and
carry on the further aggregation or whatever I want to do.
Regards,
Taher Koitawala
GS Lab Pune
+91 8407979163
