Re: using CheckpointedFunction on a keyed state

2023-09-10 Thread liu ron
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

Re: using CheckpointedFunction on a keyed state

2023-09-08 Thread Krzysztof Chmielewski
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

RE: using CheckpointedFunction on a keyed state

2023-09-07 Thread Schwalbe Matthias
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