Hi Frederick,
sorry for the delayed response.
I have no idea what the problem could be.
Has the exception been thrown from the env.execute() call?
Why did you set the akka.ask.timeout to 10k seconds?
On Wed, Jan 13, 2016 at 2:13 AM, Frederick Ayala <frederickay...@gmail.com>
wrote:
> Hi,
>
> I am having an error while running some Flink transformations in a
> DataStream Scala API.
>
> The error I get is:
>
> Timeout while waiting for JobManager answer. Job time exceeded 21474835
> seconds
> ...
>
> Caused by: akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/$a#183984057]] after [21474835000 ms]
>
>
> This happens after a couple of minutes. Not after 21474835 seconds...
>
> I tried different configurations but no result so far:
> val customConfiguration = new Configuration()
> customConfiguration.setInteger("parallelism", 8)
> customConfiguration.setInteger("jobmanager.heap.mb",2560)
> customConfiguration.setInteger("taskmanager.heap.mb",10240)
> customConfiguration.setInteger("taskmanager.numberOfTaskSlots",8)
>
> customConfiguration.setInteger("taskmanager.network.numberOfBuffers",16384)
> customConfiguration.setString("akka.ask.timeout","10000 s")
> customConfiguration.setString("akka.lookup.timeout","100 s")
> env =
> ExecutionEnvironment.createLocalEnvironment(customConfiguration)
>
> Any idea what could it be the problem?
>
> Thanks!
>
> Frederick
>
