Flink 报错 No TaskExecutor registered under container

运行Flink程序报错，具体信息如下：

org.apache.flink.runtime.resourcemanager.exceptions.UnknownTaskExecutorException: No TaskExecutor registered under container_1603071676168_0204_01_000002.at org.apache.flink.runtime.resourcemanager.ResourceManager.requestTaskManagerInfo(ResourceManager.java:583)at sun.reflect.GeneratedMethodAccessor41.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:274)at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:189)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.aroundReceive(Actor.scala:502)at akka.actor.Actor.aroundReceive$(Actor.scala:500)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 java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
2020-10-19 17:09:18,953 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1603071676168_0204_01_000003 - Remaining pending container requests: 1
2020-10-19 17:09:18,953 INFO  org.apache.flink.yarn.YarnResourceManager                     - Removing container request Capability[<memory:2048, vCores:1>]Priority[1]. Pending container requests 0.
2020-10-19 17:09:19,007 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2020-10-19 17:09:19,007 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2020-10-19 17:09:20,646 ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler  - Unhandled exception.
org.apache.flink.runtime.resourcemanager.exceptions.UnknownTaskExecutorException: No TaskExecutor registered under container_1603071676168_0204_01_000002.at org.apache.flink.runtime.resourcemanager.ResourceManager.requestTaskManagerInfo(ResourceManager.java:583)at sun.reflect.GeneratedMethodAccessor41.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:274)at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:189)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.aroundReceive(Actor.scala:502)at akka.actor.Actor.aroundReceive$(Actor.scala:500)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 java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157

报错信息：Flink No TaskExecutor registered under container_xx

描述信息：在container中没有taskExecutor注册

原因：因为有旧的Taskmanager页面打开，但是没有关闭，所以找不到对应的TaskExecutor

解决：关闭历史TaskManager页面

Flink 报错 No TaskExecutor registered under container_xx相关推荐

【Flink】Flink 报错 Writing records to streamload failed
1.概述 flink报错这个问题是 FLink是高频写入doris导致的
flink报错：The types of the interface org.apache.flink.util.OutputTag could not be inferred.
测试flink报错如下: The types of the interface org.apache.flink.util.OutputTag could not be inferred. Suppo ...
Flink 报错：unable to generate a JAAS configuration file
安装 Flink 报错:unable to generate a JAAS configuration file 原因是Flink的存放临时文件的地方,默认是 tmp/,例如我的是/data/flin ...
【Flink报错】Option not applicable to singleton quantifier
[Flink报错]Option not applicable to singleton quantifier 在使用 Flink CEP greedy 的时候遇到下面的异常. Exception in ...
flink报错：Error: Static methods in interface require -target:jvm-1.8 已解决
一.详细报错 Error:(55, 92) Static methods in interface require -target:jvm-1.8.assignTimestampsAndWaterma ...
flink报错org.apache.commons.cli.Option.builder
问题复现: yarn-session.sh 完整报错如下: SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found bindi ...
【Flink】Flink 报错 Initial AbstractPagedOutputView Segment may not be null
文章目录 1.概述 2.源码分析 1.概述写了一个FLink SQL 报错 Initial AbstractPagedOutputView Segment may not be null 写的SQL ...
【Flink】Flink 报错 ResourceManager leader changed to new address null
文章目录 1.概述 2. 源码分析 2.1 nodeChanged 2.2 handleStateChange 2.3 小结 3. 解决方案 4. 场景2 1.概述 flink HA报错如下 2021 ...
【Flink】Flink 报错 Hash join exceeded Too many duplicate keys
文章目录 1.场景1 1.1 概述 1.2 解决 1.场景1 1.1 概述 flink on hive 批处理,关联了一个字典表,flink sql做的,然后报错如下 Caused by: java. ...
Flink报错：org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold
org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold 一.问题描述 ...

Flink 报错 No TaskExecutor registered under container_xx

Flink 报错 No TaskExecutor registered under container_xx相关推荐

最新文章

热门文章