From 2c2b7a3672e0744ce6a77a117cedefba04fed603 Mon Sep 17 00:00:00 2001 From: bibinchundatt Date: Sat, 11 Nov 2017 10:36:27 +0530 Subject: [PATCH] YARN-7406. Moving logging APIs over to slf4j in hadoop-yarn-api. Contributed by Yeliang Cang. --- .../java/org/apache/hadoop/yarn/conf/HAUtil.java | 12 ++++++------ .../hadoop/yarn/util/resource/ResourceUtils.java | 8 ++++---- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/HAUtil.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/HAUtil.java index 528b6421a3f..60c370b8309 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/HAUtil.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/HAUtil.java @@ -21,8 +21,6 @@ import java.net.InetSocketAddress; import java.util.Collection; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.HadoopIllegalArgumentException; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.conf.Configuration; @@ -30,10 +28,12 @@ import org.apache.hadoop.yarn.exceptions.YarnRuntimeException; import com.google.common.annotations.VisibleForTesting; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; @InterfaceAudience.Private public class HAUtil { - private static Log LOG = LogFactory.getLog(HAUtil.class); + private static Logger LOG = LoggerFactory.getLogger(HAUtil.class); @VisibleForTesting public static final String BAD_CONFIG_MESSAGE_PREFIX = @@ -302,9 +302,9 @@ public static String getConfValueForRMInstance(String prefix, String confKey = getConfKeyForRMInstance(prefix, conf); String retVal = conf.getTrimmed(confKey); if (LOG.isTraceEnabled()) { - LOG.trace("getConfValueForRMInstance: prefix = " + prefix + - "; confKey being looked up = " + confKey + - "; value being set to = " + retVal); + LOG.trace("getConfValueForRMInstance: prefix = {};" + + " confKey being looked up = {};" + + " value being set to = {}", prefix, confKey, retVal); } return retVal; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/util/resource/ResourceUtils.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/util/resource/ResourceUtils.java index 9c9c0ef8973..1170c727ff1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/util/resource/ResourceUtils.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/util/resource/ResourceUtils.java @@ -20,8 +20,6 @@ import com.google.common.annotations.VisibleForTesting; import org.apache.commons.lang.StringUtils; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.yarn.api.protocolrecords.ResourceTypes; import org.apache.hadoop.yarn.api.records.Resource; @@ -32,6 +30,8 @@ import org.apache.hadoop.yarn.conf.YarnConfiguration; import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.exceptions.YarnRuntimeException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.FileNotFoundException; import java.io.IOException; @@ -71,7 +71,7 @@ public class ResourceUtils { private static volatile Map readOnlyNodeResources; private static volatile int numKnownResourceTypes = -1; - static final Log LOG = LogFactory.getLog(ResourceUtils.class); + static final Logger LOG = LoggerFactory.getLogger(ResourceUtils.class); private ResourceUtils() { } @@ -396,7 +396,7 @@ private static void addResourcesFileToConf(String resourceFile, } catch (FileNotFoundException fe) { LOG.info("Unable to find '" + resourceFile + "'."); } catch (IOException | YarnException ex) { - LOG.fatal("Exception trying to read resource types configuration '" + LOG.error("Exception trying to read resource types configuration '" + resourceFile + "'.", ex); throw new YarnRuntimeException(ex); }