Details
-
Sub-task
-
Status: Patch Available
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
There are a bunch of state data structures that are publicly exposed in SamzaAppState. These must be made thread-safe into accessors. These public global variables could mutated everywhere in Samza without regard for safety/visibility or correctness.
Making the SamzaAppState thread-safe will fix these potential races in code. Also, as Samza evolves, it is useful to provide accessors instead of exposing all the public variables.