Oscar Perez
05/30/2023, 2:39 PMKeyedBroadcastProcessFunction
.
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?