Re: gonna need more logs when task manager is shutting down

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/gonna-need-more-logs-when-task-manager-is-shutting-down-tp19649p19656.html

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 <[hidden email]>:

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/