If I have a keyed stream going in to a N node Flink stream processor, and I had 
a job that was keeping a count using a ValueStateDescriptor (per key), would 
that descriptor be synchronized among all the nodes? 

i.e. Are the state descriptors interfaces (ValueStateDescriptor, 
ListStateDescriptor) threadsafe?If I expose that descriptor via the 
RunTimeContext, will I get a consistent value back from each of the nodes? 

Thanks! 

Reply via email to