[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Regarding Keyed State of Connected Stream


Let's consider, I have two keyed streams one for rules and another for data and I have created a connected stream.

I am maintaining a managed keyed state (ValueState), rules stream will keep updating the state and data stream will keep reading from it.

Do I need to take a lock explicitly while updating the state or not?

I need to understand. 

Please let me know.



Garvit Sharma

No Body is a Scholar by birth, its only hard work and strong determination that makes him master.

( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-users/msg09442.html on line 70
Call Stack
10.0007363032{main}( ).../msg09442.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-users/msg09442.html on line 70
Call Stack
10.0007363032{main}( ).../msg09442.html:0