You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/30 21:08:12 UTC
[jira] [Resolved] (FLINK-2829) Confusing error message when Flink
cannot create enough task threads
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-2829.
---------------------------------
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via 77afe28eb1d5cf454f7e64be20420051c30596a2
Thank you for the contribution!
> Confusing error message when Flink cannot create enough task threads
> --------------------------------------------------------------------
>
> Key: FLINK-2829
> URL: https://issues.apache.org/jira/browse/FLINK-2829
> Project: Flink
> Issue Type: Improvement
> Components: JobManager, TaskManager
> Reporter: Gyula Fora
> Assignee: Rekha Joshi
> Priority: Trivial
> Fix For: 1.1.0
>
>
> When Flink runs out of memory while creating too many task threads, the error message received from the job manager is slightly confusing:
> 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)
> Although the error comes from the Taskmanager:
> 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)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)