Hi Muazim, In Flink, a stream of data (unless bounded) is assumed to never end.
So in your example below, this means stream 2 would NEVER be emitted, because stream 1 would never end (there is no time at which you know for sure that stream 1 is done). And this in turn means stream 2 would be buffered forever in state, thus growing unbounded. I would suggest elaborating on your use case. Regards, — Ken > On Aug 10, 2023, at 10:11 AM, Muazim Wani <muazim1...@gmail.com> wrote: > > Hi Team, > I have a use case where I have two streams and want to join them in stateful > manner . > E.g data of stream 1 should be emitted before stream2. > I tried to store the data in ListState in KeyedProcessFunction but I am not > able to access state outside proccessElement(). > Is there any way I could achieve this? > Thanks and regards > -------------------------- Ken Krugler http://www.scaleunlimited.com Custom big data solutions Flink, Pinot, Solr, Elasticsearch
