回复:Re: Re: UnknownTaskExecutorException: No TaskExecutor registered

[洪振 <ho...@163.com>]

如何退订或修改邮箱？







在 2019-05-29 11:14:47，"xuzhongjun@wsmtec.com" <xu...@wsmtec.com> 写道：
>谢谢，程序不能正常工作的问题往前找了日志发现是TaskManager内存溢出了。
>
>
>
>walt.xu
>From: Biao Liu
>Date: 2019-05-29 10:28
>To: user-zh
>Subject: Re: UnknownTaskExecutorException: No TaskExecutor registered
>你好，
>你贴的异常栈的意思是，webUI 请求的这个 TM
>已经不存在了，引起问题的原因可能是你之前在浏览器打开的一个页面无法继续访问，把这个页面关掉应该就不会报错了
>这个问题不会导致“不可用”，只是个展示错误，你说的“并且程序不能正常工作”可能是其他问题引起的
> 
>xuzhongjun@wsmtec.com <xu...@wsmtec.com> 于2019年5月27日周一 下午5:17写道：
> 
>> 大家好！
>>
>> flink启动一段时间后，一直输出以下错误日志，并且程序不能正常工作了。
>> 请问有遇到过的么，怎么解决的？
>> 是否是内存等资源不够了
>>
>> Flink版本V1.7.2
>> 2019-05-27 16:03:03,316 ERROR
>> org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler
>> - Implementation error: Unhandled exception.
>> org.apache.flink.runtime.resourcemanager.exceptions.UnknownTaskExecutorException:
>> No TaskExecutor registered under
>> container_e371_1558915641092_0246_01_000002.
>> at
>> org.apache.flink.runtime.resourcemanager.ResourceManager.requestTaskManagerInfo(ResourceManager.java:563)
>> at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
>> at
>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>> at java.lang.reflect.Method.invoke(Method.java:498)
>> at
>> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:247)
>> at
>> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
>> at
>> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:70)
>> at
>> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
>> 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)
>>
>> https://issues.apache.org/jira/browse/FLINK-8929 这有同样问题，但没有解决
>>
>>
>>
>>
>> walt.xu
>>
>>