Hello! We have been testing out the `KeyedBroadca...
# troubleshooting
o
Hello! We have been testing out the
KeyedBroadcastProcessFunction
. We have a setup in which we evaluate transaction based on some rules. The transactions are processed in the
processFunction
while on the
processBroadcastFunction
we manage and store the rules. So far, so good. The problem we are seeing is that, when redeploying, we load from a savepoint but the
broadcastState
is empty. In other words, there are no rules anymore. The taskState is loaded properly, but the broadcastState seems lost. override fun open(parameters: Configuration?) { transactionActivityWindowState = runtimeContext.getMapState(transactionsWindowDescriptor) ruleBroadcastStateDescriptor = ruleConfigBroadcastDescriptor } Is there a way to load the
broadcastState
the same way we read this
MapState
? Or how should we handle this situations?