Hi Krzysztof
Can you give the original code in initializeState method and the
corresponding exception stack trace? It looks a little interesting.
Best,
Ron
Krzysztof Chmielewski 于2023年9月9日周六 07:12写道:
> My apologies Mattthias,
> you are right. The issue was that I was trying to access state
My apologies Mattthias,
you are right. The issue was that I was trying to access state value from
open/init methods where there was not key context.
Regarding the CheckpointedFunction interface. From javadoc example and
description I got an impression that this can be used to access keyed state
on
Hi Krzysztof again,
Just for clarity … your sample code [1] tries to count the number of events per
key.
Assuming this is your intention?
Anyway your previous implementation initialized the keyed state keyCounterState
in the open function that is the right place to do this,
you just wouldn’t wa