Missed one point - I'm using Managed Operator state (and not Keyed state - as my data streams are not keyed).
On Tue, Dec 5, 2017 at 4:28 PM, Shailesh Jain <shailesh.j...@stellapps.com> wrote: > Hi, > > Is it possible to share state across operators in Flink? > > I have CoFlatMap operator which maintains a ListState and returns a > DataStream. And downstream there is a KafkaSink operator for the same > DataStream which needs to access the ListState. > > Thanks, > Shailesh >
