You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by vinay patil <vi...@gmail.com> on 2016/08/04 09:53:07 UTC

Regarding QueryableState

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.

Re: Regarding QueryableState

Posted by Vishnu Viswanath <vi...@gmail.com>.

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 <uc...@apache.org> 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 <vi...@gmail.com>
> 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.
>

Re: Regarding QueryableState

Posted by vinay patil <vi...@gmail.com>.

Thanks Ufuk, will take a look at it.

Regards,
Vinay Patil

On Thu, Aug 4, 2016 at 4:26 PM, Ufuk Celebi [via Apache Flink User Mailing
List archive.] <ml...@n4.nabble.com> 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]
> <http:///user/SendEmail.jtp?type=node&node=8325&i=0>> 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
> ml-node+s2336050n1h83@n4.nabble.com
> To unsubscribe from Apache Flink User Mailing List archive., click here
> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=1&code=dmluYXkxOC5wYXRpbEBnbWFpbC5jb218MXwxODExMDE2NjAx>
> .
> NAML
> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
>




--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-QueryableState-tp8324p8348.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Regarding QueryableState

Posted by Ufuk Celebi <uc...@apache.org>.

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 <vi...@gmail.com> 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.