If the '.state()' function returns "RUNNING" and I still get this exception?
On Fri, Mar 24, 2017 at 1:56 PM, Eno Thereska <eno.there...@gmail.com> wrote: > 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. > >
