flink git commit: [hotfix] [yarn] Improve logging of container resources

[trohrmann]

Repository: flink
Updated Branches:
  refs/heads/master 7d837a3e8 -> f7ae309d3


[hotfix] [yarn] Improve logging of container resources


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7ae309d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ae309d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f7ae309d

Branch: refs/heads/master
Commit: f7ae309d3967e61a719fadd8261d515a19ed078e
Parents: 7d837a3
Author: Till Rohrmann 
Authored: Mon Mar 12 18:38:03 2018 +0100
Committer: Till Rohrmann 
Committed: Mon Mar 12 18:38:57 2018 +0100

--
 .../main/java/org/apache/flink/yarn/YarnResourceManager.java| 5 -
 1 file changed, 4 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/f7ae309d/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
--
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 46ef81b..af789ba 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
@@ -438,7 +438,10 @@ public class YarnResourceManager extends 
ResourceManager impleme

resourceManagerClient.setHeartbeatInterval(FAST_YARN_HEARTBEAT_INTERVAL_MS);
 
numPendingContainerRequests++;
-   log.info("Requesting new TaskManager container pending 
requests: {}", numPendingContainerRequests);
+
+   log.info("Requesting new TaskExecutor container with resources 
{}. Number pending requests {}.",
+   resource,
+   numPendingContainerRequests);
}
 
private ContainerLaunchContext createTaskExecutorLaunchContext(Resource 
resource, String containerId, String host)

flink git commit: [hotfix] [yarn] Improve logging of container resources

[trohrmann]

Repository: flink
Updated Branches:
  refs/heads/release-1.5 3a3caac9f -> 84a202f15


[hotfix] [yarn] Improve logging of container resources


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84a202f1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/84a202f1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/84a202f1

Branch: refs/heads/release-1.5
Commit: 84a202f15b9b0100c9817928fc77266010e7b666
Parents: 3a3caac
Author: Till Rohrmann 
Authored: Mon Mar 12 18:38:03 2018 +0100
Committer: Till Rohrmann 
Committed: Mon Mar 12 18:39:35 2018 +0100

--
 .../main/java/org/apache/flink/yarn/YarnResourceManager.java| 5 -
 1 file changed, 4 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/84a202f1/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
--
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 46ef81b..af789ba 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
@@ -438,7 +438,10 @@ public class YarnResourceManager extends 
ResourceManager impleme

resourceManagerClient.setHeartbeatInterval(FAST_YARN_HEARTBEAT_INTERVAL_MS);
 
numPendingContainerRequests++;
-   log.info("Requesting new TaskManager container pending 
requests: {}", numPendingContainerRequests);
+
+   log.info("Requesting new TaskExecutor container with resources 
{}. Number pending requests {}.",
+   resource,
+   numPendingContainerRequests);
}
 
private ContainerLaunchContext createTaskExecutorLaunchContext(Resource 
resource, String containerId, String host)