You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/12/04 21:16:54 UTC
[flink] 02/03: [hotfix] Correct log statements in
YarnResourceManager
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b308de2153f76556e72e09f1c40fa9cf103de4d7
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Wed Dec 4 12:11:37 2019 +0100
[hotfix] Correct log statements in YarnResourceManager
---
.../src/main/java/org/apache/flink/yarn/YarnResourceManager.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
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 f615932..cf8dd72 100755
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
@@ -489,7 +489,7 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
// ------------------------------------------------------------------------
@Override
public void onContainerStarted(ContainerId containerId, Map<String, ByteBuffer> map) {
- log.debug("Succeed to call YARN Node Manager to start container", containerId);
+ log.debug("Succeeded to call YARN Node Manager to start container {}.", containerId);
}
@Override
@@ -499,7 +499,7 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
@Override
public void onContainerStopped(ContainerId containerId) {
- log.debug("Succeed to call YARN Node Manager to stop container", containerId);
+ log.debug("Succeeded to call YARN Node Manager to stop container {}.", containerId);
}
@Override
@@ -514,7 +514,7 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
@Override
public void onStopContainerError(ContainerId containerId, Throwable throwable) {
- log.warn("Error while calling YARN Node Manager to stop container {}", containerId, throwable);
+ log.warn("Error while calling YARN Node Manager to stop container {}.", containerId, throwable);
}
// ------------------------------------------------------------------------