Re: YASSQ (yet another state store question)

[Eno Thereska]

Hi Jon,

This is expected, see this: 
https://groups.google.com/forum/?pli=1#!searchin/confluent-platform/migrated$20to$20another$20instance%7Csort:relevance/confluent-platform/LglWC_dZDKw/qsPuCRT_DQAJ
 
<https://groups.google.com/forum/?pli=1#!searchin/confluent-platform/migrated$20to$20another$20instance|sort:relevance/confluent-platform/LglWC_dZDKw/qsPuCRT_DQAJ>.
 

Thanks
Eno
> On 24 Mar 2017, at 20:51, Jon Yeargers <jon.yearg...@cedexis.com> wrote:
> 
> I've setup a KTable as follows:
> 
> KTable<Windowed<String>, String> outTable = sourceStream.groupByKey().
> reduce(rowReducer,
>                TimeWindows.of(5 * 60 * 1000L).advanceBy(1 * 60 *
> 1000).until(10 * 60 * 1000L),
>                "AggStore");
> 
> I can confirm its presence via 'streams.allMetadata()' (accessible through
> a simple httpserver).
> 
> When I call 'ReadOnlyKeyValueStore<String, String> store =
> kafkaStreams.store("AggStore", QueryableStoreTypes.keyValueStore());'
> 
> I get this exception:
> 
> org.apache.kafka.streams.errors.InvalidStateStoreException: the state
> store, AggStore, may have migrated to another instance.
>        at
> org.apache.kafka.streams.state.internals.QueryableStoreProvider.getStore(QueryableStoreProvider.java:49)
>        at
> org.apache.kafka.streams.KafkaStreams.store(KafkaStreams.java:378)
>        at
> com.cedexis.videokafka.videohouraggregator.RequestHandler.handle(RequestHandler.java:97)
>        at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:79)
>        at sun.net.httpserver.AuthFilter.doFilter(AuthFilter.java:83)
>        at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:82)
>        at
> sun.net.httpserver.ServerImpl$Exchange$LinkHandler.handle(ServerImpl.java:675)
>        at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:79)
>        at sun.net.httpserver.ServerImpl$Exchange.run(ServerImpl.java:647)
>        at
> sun.net.httpserver.ServerImpl$DefaultExecutor.execute(ServerImpl.java:158)
>        at
> sun.net.httpserver.ServerImpl$Dispatcher.handle(ServerImpl.java:431)
>        at sun.net.httpserver.ServerImpl$Dispatcher.run(ServerImpl.java:396)
>        at java.lang.Thread.run(Thread.java:745)
> 
> 
> ... except.. there is only one instance.. running locally.