Re: QueryableState, unable to register KvStateRegistryListener

2016-07-21 Thread Vishnu Viswanath
Hi Ufuk, Thanks for the reply. Yes I am running in local mode (and hope it can be used in local mode) Thanks, Vishnu On Thu, Jul 21, 2016 at 4:29 AM, Ufuk Celebi wrote: > Hey Vishnu, > > thanks for trying out the PR. :-) Would be great to move future > questions to the PR. > > How are you star

Re: QueryableState, unable to register KvStateRegistryListener

2016-07-21 Thread Ufuk Celebi
Hey Vishnu, thanks for trying out the PR. :-) Would be great to move future questions to the PR. How are you starting your cluster? My guess is that you are running the cluster in local mode, which is not starting up the network components. Is that the case? – Ufuk On Thu, Jul 21, 2016 at 1:56

QueryableState, unable to register KvStateRegistryListener

2016-07-20 Thread Vishnu Viswanath
Hi, I was trying the QueryableState from the pull request https://github.com/apache/flink/pull/2051 I am doing the following: 1. Make the stream queryable by calling myKeyedStreamd.asQueryableState("my-state",myStateDescriptor) 2. Create a client that takes a job id, conf, query-name and key, nu