flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Share state across operators
Date Tue, 05 Dec 2017 11:25:53 GMT
Hi Shailesh,

sharing state across operators is not possible. However, you could emit 
the state (or parts of it) as a stream element to downstream operators 
by having a function that emits a type like 

Another option would be to use side outputs to send state to downstream 
operators [0].

Maybe you can tell use a bit more about what you want to achieve?



Am 12/5/17 um 11:58 AM schrieb Shailesh Jain:
> 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

View raw message