[
https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hiliuxg updated FLINK-15388:
----------------------------
Comment: was deleted
(was: Hi Xintong Song:
the complete log file can be download by link
https://pan.baidu.com/s/1JQJQ-U4Vif6EXR12Agql6w passwd p7ci
i jstat the recently full gc , it takes 0.921 seconds to complete the full gc
S0C S1C S0U S1U EC EU OC OU MC MU
CCSC CCSU YGC YGCT FGC FGCT GCT
0.0 753664.0 0.0 753664.0 93716480.0 32931840.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 38731776.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 44728320.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 50954240.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 57245696.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 62750720.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 67207168.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 71630848.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 75792384.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 80281600.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
0.0 753664.0 0.0 753664.0 93716480.0 84672512.0 55476224.0 34114585.2
805120.0 704223.6 0.0 0.0 25905 3870.407 1 0.921 3871.328
)
> The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.
> ------------------------------------------------------------------
>
> Key: FLINK-15388
> URL: https://issues.apache.org/jira/browse/FLINK-15388
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Task
> Affects Versions: 1.8.0
> Environment: model : standalone,not yarn
> version : flink 1.8.0
> configration :
> jobmanager.heap.size: 4096m
> taskmanager.heap.size: 144gb
> taskmanager.numberOfTaskSlots: 48
> taskmanager.memory.fraction: 0.7
> taskmanager.memory.off-heap: false
> parallelism.default: 1
>
> Reporter: hiliuxg
> Priority: Major
>
> the taskmanager's slot was removed , there was not full gc or oom , what's
> the problem ? the error bellow
> {code:java}
> org.apache.flink.util.FlinkException: The assigned slot
> bae00218c818157649eb9e3c533b86af_32 was removed.
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager.removeSlot(SlotManager.java:893)
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager.removeSlots(SlotManager.java:863)
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager.internalUnregisterTaskManager(SlotManager.java:1058)
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager.unregisterTaskManager(SlotManager.java:385)
> at
> org.apache.flink.runtime.resourcemanager.ResourceManager.closeTaskManagerConnection(ResourceManager.java:847)
> at
> org.apache.flink.runtime.resourcemanager.ResourceManager$TaskManagerHeartbeatListener$1.run(ResourceManager.java:1161)
> at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:392)
> at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:185)
> at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
> at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:147)
> at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.onReceive(FencedAkkaRpcActor.java:40)
> at
> akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
> at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
> at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
> at akka.actor.ActorCell.invoke(ActorCell.scala:495)
> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
> 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)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
