This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.6 by this push: new 57f73c8 [FLINK-10137][YARN] Log completed containers. 57f73c8 is described below commit 57f73c852714175a0989bec29607c09459a383df Author: gyao <g...@data-artisans.com> AuthorDate: Tue Aug 14 12:12:35 2018 +0200 [FLINK-10137][YARN] Log completed containers. --- .../org/apache/flink/runtime/resourcemanager/ResourceManager.java | 5 ++++- .../src/main/java/org/apache/flink/yarn/YarnResourceManager.java | 5 +++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java index ff319b4..d8a41d5 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java @@ -803,7 +803,10 @@ public abstract class ResourceManager<WorkerType extends ResourceIDRetrievable> workerRegistration.getTaskExecutorGateway().disconnectResourceManager(cause); } else { - log.debug("No open TaskExecutor connection {}. Ignoring close TaskExecutor connection.", resourceID); + log.debug( + "No open TaskExecutor connection {}. Ignoring close TaskExecutor connection. Closing reason was: {}", + resourceID, + cause.getMessage()); } } diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java index 49385e5..d051a72 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java @@ -326,9 +326,10 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme } @Override - public void onContainersCompleted(final List<ContainerStatus> list) { + public void onContainersCompleted(final List<ContainerStatus> statuses) { runAsync(() -> { - for (final ContainerStatus containerStatus : list) { + log.debug("YARN ResourceManager reported the following containers completed: {}.", statuses); + for (final ContainerStatus containerStatus : statuses) { final ResourceID resourceId = new ResourceID(containerStatus.getContainerId().toString()); final YarnWorkerNode yarnWorkerNode = workerNodeMap.remove(resourceId);