Any further information from teh log? If you create so many tasks (8 x 80) on one machine, the JVM often has not enough memory reserved for the stack space to create enough threads (1-2 threads per task)...
On Wed, Oct 7, 2015 at 2:13 PM, Gyula Fóra <gyf...@apache.org> wrote: > Hey guys, > > I am writing a job which involves creating many different sources to read > data from (in this case 80 sources wiht the parallelism of 8 each, running > locally on my mac). I cannot create less unfortunately. > > The problem is that the job fails while deploying the tasks with the > following exception: > > java.lang.Exception: Failed to deploy the task to slot SimpleSlot (1)(63) - > eea7250ab5b368693e3c4f14fb94f86d @ localhost - 8 slots - URL: > akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type > Acknowledge > at > > org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:392) > > at akka.dispatch.OnComplete.internal(Future.scala:247) > at akka.dispatch.OnComplete.internal(Future.scala:244) > at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174) > at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171) > at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) > at > > scala.concurrent.impl.ExecutionContextImpl$anon$3.exec(ExecutionContextImpl.scala:107) > > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > Any idea what might cause this? > > Cheers, > Gyula >
