Re: Regarding QueryableState

Posted by vishnuviswanath on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Regarding-QueryableState-tp8324p8326.html

Hi Ufuk,

I was able to create a QueryableState stream and query it when running in cluster mode in my local machine, but I am unable to Query the stream when running on AWS cluster, getting error AbstractMethodError at kvState.getSerializedValue(serializedKeyAndNamespace) in KvStateServerHandler.java while querying.

Not sure if I am doing something wrong here, so eagerly waiting for the merge, to try it again :)

Thanks,

Vishnu

On Thu, Aug 4, 2016 at 7:40 AM, Ufuk Celebi <[hidden email]> wrote:

You can expect it to be merged by the end of this week.

Note that the APIs are very low level at the moment though. In the PR
branch you can have a look at the QueryableStateITCase for more
details.

– Ufuk

On Thu, Aug 4, 2016 at 11:53 AM, vinay patil <[hidden email]> wrote:
> Hi All,
>
> For one use case I want to make use of this feature instead of querying
> external store like Cassandra or ES.
>
> Can you please let me know if this is under development or present in the
> master branch.
>
> It will be of great help if you can provide examples or link to the
> documentation.
>
> Thanks,
> Vinay Patil
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-QueryableState-tp8324.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.