Would you please update Flink version to 1.6.X or higher

[JaryZhen]

I'm trying to update Flink version to 1.7.2 for this demo, Booooom, I failed. So... Would please do it when you have time.Thanks lot

[uce]

@JaryZhen What failures do you get? Could you provide the stack trace, etc.?

I think the queryable state implementation has evolved quite a bit in the last two years. @kl0u, do we have an upgrade guide to the current implementation?

(cc @rmetzger)

[kl0u]

I am not familiar with the code of the demo, but the guide on how to activate and use queryable state is part of the public Flink documentation and can be found here: https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html

For example now the queryable state jar should be put in the opt folder, as described on the docs.

[uce]

Were there any breaking client changes introduced when you refactored the backend for this? And if so, did you write a migration guide for older clients?

[JaryZhen]

@kl0u I read the documentation for several times that you said above, And I tried run the code that Flink Source provide Here. But it didn't work by say:
Caused by: org.apache.flink.queryablestate.exceptions.UnknownLocationException: Could not retrieve location of state=state of job=463eb332924f1e60285d12b882d2e7ba. Potential reasons are: i) the state is not ready, or ii) the job does not exist.

@uce Hi uce. How about I commit a PR that update the code in Flink's version to 1.7.2 for this demo?

[kl0u]

@JaryZhen did you verify that the job with jobId = 463eb332924f1e60285d12b882d2e7ba is running?

The link you provide is from the end-to-end tests that are running nightly so they should always be up to date.

To see how to run it, you can check the test script https://github.com/apache/flink/blob/release-1.7/flink-end-to-end-tests/test-scripts/test_queryable_state.sh

[alpinegizmo]

@JaryZhen @uce I created a pull request a while back that updates this demo to Flink 1.6, which required making a bunch of changes. That PR could probably be improved upon, but it is enough to get the demo running on 1.6.