You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/16 21:15:13 UTC
[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15285315#comment-15285315 ]
ASF GitHub Bot commented on FLINK-2829:
---------------------------------------
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/1993
[FLINK-2829] Confusing error message when Flink cannot create enough task threads
[FLINK-2829] Confusing error message when Flink cannot create enough task threads
Clarifying the flink runtime error message on slot details on make sense for user facing them when Flink cannot create enough task threads.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rekhajoshm/flink FLINK-2829
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1993.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1993
----
commit b1f4c11f1878d53656c9ca49c6912a95a449f18e
Author: Joshi <re...@gmail.com>
Date: 2016-05-16T21:14:23Z
[FLINK-2829] Clarifying error message when Flink cannot create enough task threads
----
> 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
> Priority: Trivial
>
> 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)