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?
