I don't understand how I can save the state of a window on the
RichCoGroupFunction if the events arrive on the
RichCoGroupFunction.coCgroup only when the window closes. Then, upon a
failure I will not recover events that were on the window. This is why I
think the approach to this problem is to use
Hi Robert,
1 - I am using Kafka010 as data source.
2 - No, I am not using any kind of ListState. That I think it must be used
3 - Good. I am going to use CheckpointedFunction.
Just a follow-up question. I was reimplementing it using CoProcessFunction
to save the state and trigger the window. So,
Hi Felipe,
Which data source are you using?
> Then, in the MyCoGroupFunction there are only events of stream02
Are you storing events in your state?
> Is this the case where I have to use RichCoGroupFunction and save the
state by implementing the CheckpointedFunction?
If you want your state to
