flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: gonna need more logs when task manager is shutting down
Date Fri, 20 Apr 2018 09:54:12 GMT
Hi Makeyang,

Would you mind opening a JIRA issue [1] for your improvement suggestion?
It would be good to add the Flink version that you are running.

Thanks, Fabian

[1] https://issues.apache.org/jira/projects/FLINK

2018-04-20 6:21 GMT+02:00 makeyang <riverbuilding@hotmail.com>:

> one of my task manager is out ot the cluster and I checked its log found
> something below:
> 2018-04-19 22:34:47,441 INFO  org.apache.flink.runtime.taskmanager.Task
>
> - Attempting to fail task externally Process (115/120)
> (19d0b0ce1ef3b8023b37bdfda643ef44).
> 2018-04-19 22:34:47,441 INFO  org.apache.flink.runtime.taskmanager.Task
>
> - Process (115/120) (19d0b0ce1ef3b8023b37bdfda643ef44) switched from
> RUNNING
> to FAILED.
> java.lang.Exception: TaskManager is shutting down.
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.
> postStop(TaskManager.scala:220)
>         at akka.actor.Actor$class.aroundPostStop(Actor.scala:515)
>         at
> org.apache.flink.runtime.taskmanager.TaskManager.
> aroundPostStop(TaskManager.scala:121)
>         at
> akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$
> finishTerminate(FaultHandling.scala:210)
>         at
> akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
>         at akka.actor.ActorCell.terminate(ActorCell.scala:374)
>         at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:467)
>         at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
>         at akka.dispatch.Mailbox.processAllSystemMessages(
> Mailbox.scala:282)
>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:260)
>         at akka.dispatch.Mailbox.run(Mailbox.scala:224)
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
>         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)
>
> well,
> Attempting to fail task externally Process due to what?
> when task manager is shutting down and due to what?
>
> these import info is not found in log which is actually very useful
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>

Mime
View raw message