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
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
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