[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15382486#comment-15382486 ]
ASF GitHub Bot commented on FLINK-4152: --------------------------------------- Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2257#discussion_r71173613 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java --- @@ -78,6 +79,9 @@ /** The containers where a TaskManager is starting and we are waiting for it to register */ private final Map<ResourceID, YarnContainerInLaunch> containersInLaunch; + /** The container where a TaskManager has been started and is running in */ + private final Map<ResourceID, Container> containersLaunched; --- End diff -- Why this map? There is already a map in the base class which holds the registered resources. > 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 > Assignee: Till Rohrmann > Attachments: logs.tgz > > > 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)