Hi All, Due to the way our code is structured, we would like to use the broadcast state at multiple points of our pipeline. So not only share it between multiple instances of the same operator but also between multiple operators. See the image below for a simplified example.
Flink does not seem to have any problems with this at runtime but I wonder: - Is this a good pattern and was it designed with something like this in mind? - If we use the same MapStateDescriptor in both operators, does the state only get stored once? And does it also only get written once? [image: broadcast-state.png] Thanks!
