Hi All, I'm running a streaming job on flink 1.3.2 with few queryable states. There are 3 task managers and a job manager. I'm getting timeout exception when trying to query a state and also a warning message in the job manager log.
*Client:* final Configuration config = new Configuration(); config.setString(JobManagerOptions.ADDRESS, jobMgrHost); config.setInteger(JobManagerOptions.PORT, JobManagerOptions.PORT.defaultValue()); final HighAvailabilityServices highAvailabilityServices = HighAvailabilityServicesUtils.createHighAvailabilityServices( config, Executors.newSingleThreadScheduledExecutor(), HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION); QueryableStateClient client = new QueryableStateClient(config, highAvailabilityServices); *Exception:* Exception in thread "main" io.netty.channel.ConnectTimeoutException: connection timed out: /172.31.18.170:43537 at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:212) at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) at java.lang.Thread.run(Thread.java:745) *Job Manager:* 2017-09-10 06:55:41,599 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp:// flink@127.0.0.1:64344] has failed, address is now gated for [5000] ms. Reason: [Disassociated] Thanks, Navneeth