| commit | 00a844adedd2b86d3c2ea55a58a4a743c1724aaf | [log] [tgz] |
|---|---|---|
| author | Yuliya Feldman <yuliya@dremio.com> | Wed Feb 28 14:52:56 2018 -0800 |
| committer | Terence Yim <chtyim@apache.org> | Thu Mar 01 10:07:14 2018 -0800 |
| tree | c178bfee85e404f4e4546a74fee1d1e2416666c1 | |
| parent | d6095d4876d55c8e614a11bf66d780e0856481f8 [diff] |
(TWILL-255) Incorrect logging after memory was adjusted. Does not show memory before adjustment This closes #66 on Github. Signed-off-by: Terence Yim <chtyim@apache.org>
diff --git a/twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAMClient.java b/twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAMClient.java index 67bef3e..76de0c0 100644 --- a/twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAMClient.java +++ b/twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAMClient.java
@@ -126,8 +126,8 @@ updatedMemory = (int) Math.ceil(((double) updatedMemory / minMemory)) * minMemory; if (resource.getMemory() != updatedMemory) { - resource.setMemory(updatedMemory); LOG.info("Adjust memory requirement from {} to {} MB.", resource.getMemory(), updatedMemory); + resource.setMemory(updatedMemory); } return resource;
diff --git a/twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAMClient.java b/twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAMClient.java index f349b4e..42bff62 100644 --- a/twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAMClient.java +++ b/twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAMClient.java
@@ -165,8 +165,8 @@ int updatedMemory = Math.min(resource.getMemory(), maxCapability.getMemory()); if (resource.getMemory() != updatedMemory) { - resource.setMemory(updatedMemory); LOG.info("Adjust memory requirement from {} to {} MB.", resource.getMemory(), updatedMemory); + resource.setMemory(updatedMemory); } return resource;