Regarding QueryableState

[Vinay Patil]

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

[Ufuk Celebi]

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.

[vishnuviswanath]

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.

[Vinay Patil]

Thanks Ufuk, will take a look at it.

On Thu, Aug 4, 2016 at 4:26 PM, Ufuk Celebi [via Apache Flink User Mailing List archive.] <[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.

---

If you reply to this email, your message will be added to the discussion below:

http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-QueryableState-tp8324p8325.html

To start a new topic under Apache Flink User Mailing List archive., email [hidden email]
To unsubscribe from Apache Flink User Mailing List archive., click here.
NAML