Hi All, Any suggestions would really be helpful. Thanks
On Sun, Sep 10, 2017 at 12:04 AM, Navneeth Krishnan < reachnavnee...@gmail.com> wrote: > 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 > > >
