You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/08/29 12:24:57 UTC
[flink] branch release-1.6 updated: [FLINK-10137][YARN] Log
completed containers.
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 <ga...@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);