Re: Error querying flink state

2021-01-20 Thread Till Rohrmann
Hi Falak, it is hard to tell what is going wrong w/o the debug logs. Could you check whether they contain anything specific? You can also share them with us. Cheers, Till On Wed, Jan 20, 2021 at 1:04 PM Falak Kansal wrote: > Hi, > > Thank you so much for the response. I am using the 1.12 versi

Re: Error querying flink state

2021-01-18 Thread Till Rohrmann
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 th

Fwd: Error querying flink state

2021-01-14 Thread Falak Kansal
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