[flink] branch release-1.5 updated: [FLINK-10137][YARN] Log completed containers.

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.5 by this push:
     new 3360c39  [FLINK-10137][YARN] Log completed containers.
3360c39 is described below

commit 3360c3971fbfc878b9469872045fe515e25c8697
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 729cdef..2b4e9fb 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
@@ -325,9 +325,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);