[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362433#comment-15362433
]
Robert Metzger commented on FLINK-4152:
---------------------------------------
The full aggregated YARN log is more than 300 MB ...
I'm not sure what the root cause of this issue is. Somewhere there seems to be
a retry mechanism not using any backoff.
In the JobManager, there are many messages like this
{code}
2016-07-05 09:57:10,032 INFO org.apache.flink.yarn.YarnFlinkResourceManager
- Requesting new TaskManager container with 1024 megabytes memory.
Pending requests: 1
2016-07-05 09:57:10,033 INFO org.apache.flink.yarn.YarnFlinkResourceManager
- Requesting new TaskManager container with 1024 megabytes memory.
Pending requests: 2
2016-07-05 09:57:10,033 INFO org.apache.flink.yarn.YarnFlinkResourceManager
- Requesting new TaskManager container with 1024 megabytes memory.
Pending requests: 3
2016-07-05 09:57:10,033 INFO org.apache.flink.yarn.YarnFlinkResourceManager
- Requesting new TaskManager container with 1024 megabytes memory.
Pending requests: 4
2016-07-05 09:57:10,054 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000003'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000003'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2016-07-05 09:57:10,058 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000004'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000004'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2016-07-05 09:57:10,059 WARN org.apache.flink.yarn.YarnJobManager
- TaskManager's resource id
ResourceID{resourceId='container_1467643389376_0026_01_000003'} failed to
register at ResourceManager. Refusing registration because of
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000003'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
.
2016-07-05 09:57:10,059 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000005'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000005'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2016-07-05 09:57:10,059 WARN org.apache.flink.yarn.YarnJobManager
- TaskManager's resource id
ResourceID{resourceId='container_1467643389376_0026_01_000004'} failed to
register at ResourceManager. Refusing registration because of
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000004'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
.
2016-07-05 09:57:10,060 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000002'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000002'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2016-07-05 09:57:10,060 WARN org.apache.flink.yarn.YarnJobManager
- TaskManager's resource id
ResourceID{resourceId='container_1467643389376_0026_01_000005'} failed to
register at ResourceManager. Refusing registration because of
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000005'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
.
2016-07-05 09:57:10,061 WARN org.apache.flink.yarn.YarnJobManager
- TaskManager's resource id
ResourceID{resourceId='container_1467643389376_0026_01_000002'} failed to
register at ResourceManager. Refusing registration because of
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000002'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
.
2016-07-05 09:57:10,543 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000004'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000004'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2016-07-05 09:57:10,544 WARN org.apache.flink.yarn.YarnFlinkResourceManager
- TaskManager resource registration failed for
ResourceID{resourceId='container_1467643389376_0026_01_000002'}
java.lang.Exception: Cannot register Worker - unknown resource id
ResourceID{resourceId='container_1467643389376_0026_01_000002'}
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:329)
at
org.apache.flink.yarn.YarnFlinkResourceManager.workerRegistered(YarnFlinkResourceManager.java:66)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleRegisterResource(FlinkResourceManager.java:362)
at
org.apache.flink.runtime.clusterframework.FlinkResourceManager.handleMessage(FlinkResourceManager.java:235)
at
org.apache.flink.yarn.YarnFlinkResourceManager.handleMessage(YarnFlinkResourceManager.java:169)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
at
org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
at
akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
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}
> TaskManager registration exponential backoff doesn't work
> ---------------------------------------------------------
>
> Key: FLINK-4152
> URL: https://issues.apache.org/jira/browse/FLINK-4152
> Project: Flink
> Issue Type: Bug
> Components: Distributed Coordination, TaskManager, YARN Client
> Reporter: Robert Metzger
>
> While testing Flink 1.1 I've found that the TaskManagers are logging many
> messages when registering at the JobManager.
> This is the log file:
> https://gist.github.com/rmetzger/0cebe0419cdef4507b1e8a42e33ef294
> Its logging more than 3000 messages in less than a minute. I don't think that
> this is the expected behavior.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
