akka.pattern.AskTimeoutException

[Frederick Ayala]

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