Hi Falak, Which version of Flink are you using? Providing us with the debug logs could also help understanding what's going wrong.
I guess that you have copied the flink-queryable-state-runtime jar into the lib directory and set queryable-state.enable: true in the configuration, right? Here is the link to the documentation for queryable state [1] for more details. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html Cheers, Till On Thu, Jan 14, 2021 at 1:18 PM Falak Kansal <falakkansa...@gmail.com> wrote: > > Hi, > > I have set up a flink cluster on my local machine. I created a flink job ( > TrackMaximumTemperature) and made the state queryable. I am using > *github/streamingwithflink/chapter7/QueryableState.scala* example from > *https://github.com/streaming-with-flink > <https://github.com/streaming-with-flink>* repository. Please find the > file attached. > > Now i have the running job id and when i go and try to access the state, > it throws an exception. I see the job is running and I am using the correct > jobId. Also checkpointing is enabled in the original job and i have set the > properties related to checkpointing in flink-conf.yaml. Am I > missing something? Any leads will be appreciated. Thank you :) > > > *Exception stack trace:* > Caused by: > org.apache.flink.queryablestate.exceptions.UnknownLocationException: Could > not retrieve location of state=maxTemperature of > job=9a528bf3e1b650aed7e0b1e26d038ad5. Potential reasons are: i) the state > is not ready, or ii) the job does not exist. > at > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler.getKvStateLookupInfo(KvStateClientProxyHandler.java:228) > at > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler.getState(KvStateClientProxyHandler.java:162) > at > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler.executeActionAsync(KvStateClientProxyHandler.java:129) > at > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler.handleRequest(KvStateClientProxyHandler.java:119) > at > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler.handleRequest(KvStateClientProxyHandler.java:63) > at > org.apache.flink.queryablestate.network.AbstractServerHandler$AsyncRequestTask.run(AbstractServerHandler.java:236) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >
