YARN-7407. Moving logging APIs over to slf4j in hadoop-yarn-applications. Contributed by Yeliang Cang.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/785f1b0d Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/785f1b0d Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/785f1b0d Branch: refs/heads/YARN-1011 Commit: 785f1b0d11a3bf0af9851c080ff0acc34539f17b Parents: fad22d8 Author: Akira Ajisaka <aajis...@apache.org> Authored: Tue Oct 31 16:36:02 2017 +0900 Committer: Akira Ajisaka <aajis...@apache.org> Committed: Tue Oct 31 16:36:02 2017 +0900 ---------------------------------------------------------------------- .../distributedshell/ApplicationMaster.java | 13 +++++++------ .../yarn/applications/distributedshell/Client.java | 9 +++++---- .../ContainerLaunchFailAppMaster.java | 10 +++++----- .../distributedshell/TestDSFailedAppMaster.java | 7 ++++--- .../distributedshell/TestDSSleepingAppMaster.java | 8 +++++--- .../distributedshell/TestDistributedShell.java | 14 +++++++------- .../TestDistributedShellWithNodeLabels.java | 8 ++++---- .../unmanagedamlauncher/UnmanagedAMLauncher.java | 9 +++++---- .../unmanagedamlauncher/TestUnmanagedAMLauncher.java | 12 ++++++------ 9 files changed, 48 insertions(+), 42 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java index 6d838c0..91dbc00 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java @@ -47,8 +47,6 @@ import org.apache.commons.cli.GnuParser; import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.classification.InterfaceAudience.Private; import org.apache.hadoop.classification.InterfaceStability; @@ -113,6 +111,8 @@ import org.apache.log4j.LogManager; import com.google.common.annotations.VisibleForTesting; import com.sun.jersey.api.client.ClientHandlerException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * An ApplicationMaster for executing shell commands on a set of launched @@ -179,7 +179,8 @@ import com.sun.jersey.api.client.ClientHandlerException; @InterfaceStability.Unstable public class ApplicationMaster { - private static final Log LOG = LogFactory.getLog(ApplicationMaster.class); + private static final Logger LOG = LoggerFactory + .getLogger(ApplicationMaster.class); @VisibleForTesting @Private @@ -349,7 +350,7 @@ public class ApplicationMaster { appMaster.run(); result = appMaster.finish(); } catch (Throwable t) { - LOG.fatal("Error running ApplicationMaster", t); + LOG.error("Error running ApplicationMaster", t); LogManager.shutdown(); ExitUtil.terminate(1, t); } @@ -388,7 +389,7 @@ public class ApplicationMaster { } catch (IOException e) { e.printStackTrace(); } finally { - IOUtils.cleanup(LOG, buf); + IOUtils.cleanupWithLogger(LOG, buf); } } @@ -630,7 +631,7 @@ public class ApplicationMaster { LOG.info("Executing with tokens:"); while (iter.hasNext()) { Token<?> token = iter.next(); - LOG.info(token); + LOG.info(token.toString()); if (token.getKind().equals(AMRMTokenIdentifier.KIND_NAME)) { iter.remove(); } http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java index 1a97304..0582afe 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java @@ -36,8 +36,6 @@ import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; import org.apache.commons.io.IOUtils; import org.apache.commons.lang.StringUtils; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; @@ -85,6 +83,8 @@ import org.apache.hadoop.yarn.exceptions.YARNFeatureNotEnabledException; import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.util.resource.Resources; import org.apache.hadoop.yarn.util.timeline.TimelineUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Client for Distributed Shell application submission to YARN. @@ -121,7 +121,8 @@ import org.apache.hadoop.yarn.util.timeline.TimelineUtils; @InterfaceStability.Unstable public class Client { - private static final Log LOG = LogFactory.getLog(Client.class); + private static final Logger LOG = LoggerFactory + .getLogger(Client.class); private static final int DEFAULT_AM_MEMORY = 100; private static final int DEFAULT_AM_VCORES = 1; @@ -237,7 +238,7 @@ public class Client { } result = client.run(); } catch (Throwable t) { - LOG.fatal("Error running Client", t); + LOG.error("Error running Client", t); System.exit(1); } if (result) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ContainerLaunchFailAppMaster.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ContainerLaunchFailAppMaster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ContainerLaunchFailAppMaster.java index 8e561c6..1d41c0d 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ContainerLaunchFailAppMaster.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ContainerLaunchFailAppMaster.java @@ -21,14 +21,14 @@ package org.apache.hadoop.yarn.applications.distributedshell; import java.nio.ByteBuffer; import java.util.Map; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.yarn.api.records.ContainerId; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class ContainerLaunchFailAppMaster extends ApplicationMaster { - private static final Log LOG = - LogFactory.getLog(ContainerLaunchFailAppMaster.class); + private static final Logger LOG = + LoggerFactory.getLogger(ContainerLaunchFailAppMaster.class); public ContainerLaunchFailAppMaster() { super(); @@ -69,7 +69,7 @@ public class ContainerLaunchFailAppMaster extends ApplicationMaster { appMaster.run(); result = appMaster.finish(); } catch (Throwable t) { - LOG.fatal("Error running ApplicationMaster", t); + LOG.error("Error running ApplicationMaster", t); System.exit(1); } if (result) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSFailedAppMaster.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSFailedAppMaster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSFailedAppMaster.java index 26022d4..4f424f9 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSFailedAppMaster.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSFailedAppMaster.java @@ -20,13 +20,14 @@ package org.apache.hadoop.yarn.applications.distributedshell; import java.io.IOException; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.yarn.exceptions.YarnException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class TestDSFailedAppMaster extends ApplicationMaster { - private static final Log LOG = LogFactory.getLog(TestDSFailedAppMaster.class); + private static final Logger LOG = LoggerFactory + .getLogger(TestDSFailedAppMaster.class); @Override public void run() throws YarnException, IOException, InterruptedException { http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSSleepingAppMaster.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSSleepingAppMaster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSSleepingAppMaster.java index 3004b69..25975bf 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSSleepingAppMaster.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSSleepingAppMaster.java @@ -18,12 +18,14 @@ package org.apache.hadoop.yarn.applications.distributedshell; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class TestDSSleepingAppMaster extends ApplicationMaster{ - private static final Log LOG = LogFactory.getLog(TestDSSleepingAppMaster.class); + private static final Logger LOG = LoggerFactory + .getLogger(TestDSSleepingAppMaster.class); private static final long SLEEP_TIME = 5000; public static void main(String[] args) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java index 0041c08..5cf884b 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java @@ -39,8 +39,6 @@ import java.util.List; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.commons.io.FileUtils; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.CommonConfigurationKeysPublic; import org.apache.hadoop.fs.FileContext; @@ -96,11 +94,13 @@ import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; import org.junit.rules.Timeout; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class TestDistributedShell { - private static final Log LOG = - LogFactory.getLog(TestDistributedShell.class); + private static final Logger LOG = + LoggerFactory.getLogger(TestDistributedShell.class); protected MiniYARNCluster yarnCluster = null; protected MiniDFSCluster hdfsCluster = null; @@ -892,11 +892,11 @@ public class TestDistributedShell { }; //Before run the DS, the default the log level is INFO - final Log LOG_Client = - LogFactory.getLog(Client.class); + final Logger LOG_Client = + LoggerFactory.getLogger(Client.class); Assert.assertTrue(LOG_Client.isInfoEnabled()); Assert.assertFalse(LOG_Client.isDebugEnabled()); - final Log LOG_AM = LogFactory.getLog(ApplicationMaster.class); + final Logger LOG_AM = LoggerFactory.getLogger(ApplicationMaster.class); Assert.assertTrue(LOG_AM.isInfoEnabled()); Assert.assertFalse(LOG_AM.isDebugEnabled()); http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShellWithNodeLabels.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShellWithNodeLabels.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShellWithNodeLabels.java index 143e5c4..e9ba6e8 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShellWithNodeLabels.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShellWithNodeLabels.java @@ -21,8 +21,6 @@ import java.io.IOException; import java.util.HashSet; import java.util.Set; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.yarn.api.records.NodeId; import org.apache.hadoop.yarn.server.nodemanager.NodeManager; @@ -34,10 +32,12 @@ import org.junit.Before; import org.junit.Test; import com.google.common.collect.ImmutableMap; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class TestDistributedShellWithNodeLabels { - private static final Log LOG = - LogFactory.getLog(TestDistributedShellWithNodeLabels.class); + private static final Logger LOG = + LoggerFactory.getLogger(TestDistributedShellWithNodeLabels.class); static final int NUM_NMS = 2; TestDistributedShell distShellTest; http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/UnmanagedAMLauncher.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/UnmanagedAMLauncher.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/UnmanagedAMLauncher.java index 030a730..f3bb5fd 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/UnmanagedAMLauncher.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/UnmanagedAMLauncher.java @@ -36,8 +36,6 @@ import org.apache.commons.cli.GnuParser; import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.security.Credentials; @@ -60,6 +58,8 @@ import org.apache.hadoop.yarn.conf.YarnConfiguration; import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.security.AMRMTokenIdentifier; import org.apache.hadoop.yarn.util.Records; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * The UnmanagedLauncher is a simple client that launches and unmanaged AM. An @@ -75,7 +75,8 @@ import org.apache.hadoop.yarn.util.Records; * report app completion. */ public class UnmanagedAMLauncher { - private static final Log LOG = LogFactory.getLog(UnmanagedAMLauncher.class); + private static final Logger LOG = LoggerFactory + .getLogger(UnmanagedAMLauncher.class); private Configuration conf; @@ -110,7 +111,7 @@ public class UnmanagedAMLauncher { } client.run(); } catch (Throwable t) { - LOG.fatal("Error running Client", t); + LOG.error("Error running Client", t); System.exit(1); } } http://git-wip-us.apache.org/repos/asf/hadoop/blob/785f1b0d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/TestUnmanagedAMLauncher.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/TestUnmanagedAMLauncher.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/TestUnmanagedAMLauncher.java index 3aba01a..134cba8 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/TestUnmanagedAMLauncher.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/TestUnmanagedAMLauncher.java @@ -28,8 +28,6 @@ import java.io.IOException; import java.io.OutputStream; import java.net.URL; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.net.NetUtils; import org.apache.hadoop.yarn.api.ApplicationMasterProtocol; @@ -47,10 +45,12 @@ import org.junit.AfterClass; import org.junit.Assert; import org.junit.BeforeClass; import org.junit.Test; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class TestUnmanagedAMLauncher { - private static final Log LOG = LogFactory - .getLog(TestUnmanagedAMLauncher.class); + private static final Logger LOG = LoggerFactory + .getLogger(TestUnmanagedAMLauncher.class); protected static MiniYARNCluster yarnCluster = null; protected static Configuration conf = new YarnConfiguration(); @@ -128,7 +128,7 @@ public class TestUnmanagedAMLauncher { String classpath = getTestRuntimeClasspath(); String javaHome = System.getenv("JAVA_HOME"); if (javaHome == null) { - LOG.fatal("JAVA_HOME not defined. Test not running."); + LOG.error("JAVA_HOME not defined. Test not running."); return; } String[] args = { @@ -170,7 +170,7 @@ public class TestUnmanagedAMLauncher { String classpath = getTestRuntimeClasspath(); String javaHome = System.getenv("JAVA_HOME"); if (javaHome == null) { - LOG.fatal("JAVA_HOME not defined. Test not running."); + LOG.error("JAVA_HOME not defined. Test not running."); return; } String[] args = { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org