flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vishnu Viswanath <vishnu.viswanat...@gmail.com>
Subject Re: Job submission timeout
Date Wed, 23 Aug 2017 06:45:27 GMT
Never mind, it was a silly mistake, I used "=" instead of ":" while setting
akka.ask.timeout.

Now it works fine!

On Tue, Aug 22, 2017 at 5:10 PM, Vishnu Viswanath <
vishnu.viswanath25@gmail.com> wrote:

> Hi,
>
> After I submit the job the client timeout after 10 seconds( Guess Job
> manager is taking long time to build the graph, it is a pretty big
> JobGraph).
>
> *Caused by: org.apache.flink.runtime.client.JobTimeoutException:
> JobManager did not respond within 10000 milliseconds*
> * at
> org.apache.flink.runtime.client.JobClient.submitJobDetached(JobClient.java:441)*
> * at
> org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.handleJsonRequest(JarRunHandler.java:69)*
> * ... 34 more*
> *Caused by: java.util.concurrent.TimeoutException: Futures timed out after
> [10000 milliseconds]*
> * at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)*
> * at
> scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)*
> * at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190)*
> * at
> scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)*
> * at scala.concurrent.Await$.result(package.scala:190)*
> * at scala.concurrent.Await.result(package.scala)*
> * at
> org.apache.flink.runtime.client.JobClient.submitJobDetached(JobClient.java:437)*
> * ... 35 more*
>
> I tried increase akka.ask.timeout to 1 min in flink-conf.yaml but didn't
> help. Can someone point me to the correct property?
>
> Thanks,
> Vishnu
>

Mime
View raw message