Hello Florian, In PAPI, you need to associate the state store with the processor node via the Topology#addStateStore(StoreBuilder); note that StateStore#init() is supposed to be triggered by the Streams library only but not by the users: it is called when the library is constructing the specified topology.
Guozhang On Tue, Nov 7, 2017 at 12:59 PM, Florian Hussonnois <[email protected]> wrote: > Hi, > > Currently it's possible to register a store from a Processor instance via > the method StateStore#init(ProcessorContext, StateStore). > > However, when this method is used the registered store seems to never be > add to the the variable ProcessorNode#stateStores which is leading > to Invalid topology building exception when accessing store with the method > ProcessorContext#getStateStore > > Is it the desired behavior or a bug ? > > -- > Florian HUSSONNOIS > -- -- Guozhang
