I think the error message could have been better, though... This actually warrants a JIRA issue...
On Wed, Oct 7, 2015 at 2:44 PM, Gyula Fóra <gyula.f...@gmail.com> wrote: > Thanks! > > Yes, it was indeed a memory issue: > java.lang.OutOfMemoryError: unable to create new native thread > at java.lang.Thread.start0(Native Method) > at java.lang.Thread.start(Thread.java:714) > at org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:415) > at > > org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:904) > > I will just decrease the parallelism locally :) > > Cheers, > Gyula > > Stephan Ewen <se...@apache.org> ezt írta (időpont: 2015. okt. 7., Sze, > 14:16): > > > 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 > > > > > >
