Loading... |
Reply to author |
Edit post |
Move post |
Delete this post |
Delete this post and replies |
Change post date |
Print post |
Permalink |
Raw mail |
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/ |
Loading... |
Reply to author |
Edit post |
Move post |
Delete this post |
Delete this post and replies |
Change post date |
Print post |
Permalink |
Raw mail |
Hi Makeyang, Would you mind opening a JIRA issue [1] for your improvement suggestion?[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 ... [show rest of quote] |
Free forum by Nabble | Edit this page |