Hi,
This should not happen. I guess the `onTimer` and `processElement` you are
testing are triggered under different keyby keys. Note that the keyed
states are partitioned by the keyby key first, so if querying or setting
the state, you are only manipulating the specific partition which does not
a
Hi all:
KeyBy process function
EventKeyedBroadcastProcessFunction {
private transient mapstate = null;
public void open(Configuration parameters) throws Exception {
// initial map state
}
public void processElement() {
// can't get onTimer() function s
