You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Vishnu Viswanath <vi...@gmail.com> on 2017/08/22 21:10:30 UTC

Job submission timeout

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

Re: Job submission timeout

Posted by Vishnu Viswanath <vi...@gmail.com>.

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
>