flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Olson <technol...@nododos.com>
Subject State Descriptors / Queryable State Question
Date Thu, 26 Jan 2017 13:10:43 GMT
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? 


View raw message