Oh....that won't work for me either. I needed to use MapState. Perhaps I should describe my problem. I am using a KeyedState process function, but the workload that it is processing is not distributing well across the cluster. I have four task managers, but the way my data is keyed in this operator, it only goes to one task manager node.
I need state, but I don't really need it keyed. On Sat, Jun 5, 2021 at 4:56 AM Marco Villalobos <mvillalo...@kineteque.com> wrote: > Does that work in the DataStream API in Batch Execution Mode? > > On Sat, Jun 5, 2021 at 12:04 AM JING ZHANG <beyond1...@gmail.com> wrote: > >> Hi, >> please use `CheckpointedFunction`, you could initialize your operator >> state in `initializeState` method by using >> context.getOperatorStateStore().*** >> >> Best regards, >> JING ZHANG >> >> >> Marco Villalobos <mvillalo...@kineteque.com> 于2021年6月5日周六 下午1:55写道： >> >>> Is it possible to use OperatorState, when NOT implementing a source or >>> sink function? >>> >>> If yes, then how? >>> >>
