You should be able to use queryable state w/o any changes to the default config. The `query.server.port` option defines the port of the queryable state server that serves the state on the task managers and it is enabled by default.
The important thing is to configure the client to discover the JobManager and everything else should work out of the box. Can you please 1) Use the default config and verify in the JobManager logs that the JobManager listens on port 6123 (the default JM port) and that all expected TaskManagers connect to it? 2) Share the code for how you configure the QueryableStateClient? – Ufuk On Mon, Apr 24, 2017 at 1:45 PM, Chet Masterson <chet.master...@yandex.com> wrote: > I moved up from running queryable state on a standalone Flink instance to a > several node cluster. My queries don't seem to be responding when I execute > them on the cluster. A few questions: > > 1. The error I am getting: > WARN [ReliableDeliverySupervisor] Association with remote system > [akka.tcp://flink@x.x.x.x:6123] has failed, address is now gated for [5000] > ms. Reason: [Association failed with [akka.tcp://flink@x.x.x.x:6123]] Caused > by: [Connection refused: /x.x.x.x:6123] > 2017/04/23 20:19:01.016 ERROR Actor not found for: > ActorSelection[Anchor(akka.tcp://flink@x.x.x.x:6123/), > Path(/user/jobmanager)] > > I assume this is because Flink is not servicing requests on port :6123. I am > using the default RPC ports defined in flink-conf.yaml. I confirm nothing is > listening on port 6123 by using netstat on the flink nodes. > > 2. I make the following changes on all nodes to flink-conf.yaml, then > restart the cluster > > #jobmanager.rpc.port: 6123 > query.server.port: 6123 > query.server.enable: true > > 3. Now port 6123 is open, as viewed from netstat. > > My question: what is the proper configuration for servicing external queries > when running in a cluster? Can I use jobmanager.rpc.port: 6123 which works > standalone, do I have to add query.server.port and query.server.enable? > Which port should I be using? > >
