Re: Using Queryable State within 1 job + docs suggestion

Posted by Yun Tang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Using-Queryable-State-within-1-job-docs-suggestion-tp35227p35239.html

Hi Annemarie

First of all, I'm afraid Flink does not support to make window state as queryable currently. It was planed to support but haven't implemented as lack of continuous development in this area for Flink community.

Secondly, I think the doc just want to tell user how to enable this feature on server side as Flink job needs to access the queryable-state classes. If you're just running your Flink job locally, add dependency could let your local job access the queryable-state classes which is actually the doc wanted to tell users.

Best

Yun Tang

---

From: Annemarie Burger <[hidden email]>
Sent: Monday, May 18, 2020 23:13
To: [hidden email] <[hidden email]>
Subject: Using Queryable State within 1 job + docs suggestion

 

Hi,

I want to use Queryable State to communicate between PU's in the same Flink
job. I'm aware this is not the intended use of Queryable State, but I was
wondering if and how it could be done.
More specifically, I want to query the (event-time) window state of one PU,
from another PU, while both are in the same window. Any suggestions?

Also, when I was trying to get Queryable state working in my IDE, this took
quite a while because the  docs
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html#activating-queryable-state>  
state "copy the flink-queryable-state-runtime_2.11-1.10.0.jar from the opt/
folder of your Flink distribution, to the lib/ folder.". This seems to be
only relevant if you're using a local version of Flink. If you're using the
Maven dependencies you can achieve the same effect by adding the
queryable-state-runtime dependency. It could be helpful for other users to
mention this in the docs.

Best,
Annemarie



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/