You could try to set queryable-state.enable to true. And check again. Vishal Santoshi <vishal.santo...@gmail.com>于2019年4月25日 周四上午1:40写道:
> Any one ? > > On Wed, Apr 24, 2019 at 12:02 PM Vishal Santoshi < > vishal.santo...@gmail.com> wrote: > >> Hello folks, >> >> Following >> https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html#querying-state >> . >> for setting up the Queryable Server and proxy, I have my classpath ( the >> lib directory ) that has the required jar, But I do not see the mentioned >> log and of course am not able to set up the QS server/Proxy . This has >> worked on 1.7.2 and I think I have everything as advised, see the logs >> below. I do not see this log "Started the Queryable State Proxy Server >> @ ...". Any one with this issue... >> >> >> >> 2019-04-24 15:54:26,296 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - -Dtaskmanager.numberOfTaskSlots=1 >> >> 2019-04-24 15:54:26,296 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - --configDir >> >> 2019-04-24 15:54:26,296 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - /usr/local/flink/conf >> >> 2019-04-24 15:54:26,296 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - Classpath: >> /usr/local/flink/lib/flink-metrics-prometheus-1.8.0.jar: >> */usr/local/flink/lib/flink-queryable-state-runtime_2.11-1.8.0.jar* >> :/usr/local/flink/lib/hadoop.jar:/usr/local/flink/lib/jobs.jar:/usr/local/flink/lib/log4j-1.2.17.jar:/usr/local/flink/lib/slf4j-log4j12-1.7.15.jar:/usr/local/flink/lib/flink-dist_2.11-1.8.0.jar::: >> >> 2019-04-24 15:54:26,296 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - >> -------------------------------------------------------------------------------- >> >> 2019-04-24 15:54:26,298 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - Registered UNIX signal handlers for [TERM, HUP, INT] >> >> 2019-04-24 15:54:26,300 INFO >> org.apache.flink.runtime.taskexecutor.TaskManagerRunner >> - Maximum number of open file descriptors is 65536. >> >> 2019-04-24 15:54:26,305 INFO >> org.apache.flink.configuration.GlobalConfiguration - Loading >> configuration property: state.backend.fs.checkpointdir, >> hdfs:///flink-checkpoints_k8s_test/prod >> >> 2 >> >> >> >> >> -- Best, Guowei