sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: SQOOP-672: Unify logger usage across entire code base
Date Fri, 12 Jul 2013 00:29:32 GMT
Updated Branches:
  refs/heads/sqoop2 76fbc835c -> 1f016abb9


SQOOP-672: Unify logger usage across entire code base

(Raghav Kumar Gautam via Jarek Jarcec Cecho)


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

Branch: refs/heads/sqoop2
Commit: 1f016abb93a5e44ee9813ff11753d88553f07370
Parents: 76fbc83
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Authored: Thu Jul 11 17:28:44 2013 -0700
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
Committed: Thu Jul 11 17:28:44 2013 -0700

----------------------------------------------------------------------
 .../sqoop/connector/jdbc/GenericJdbcImportDestroyer.java      | 3 ++-
 core/src/main/java/org/apache/sqoop/framework/JobManager.java | 2 +-
 .../java/org/apache/sqoop/job/etl/HdfsExportExtractor.java    | 5 ++---
 .../main/java/org/apache/sqoop/job/mr/ProgressRunnable.java   | 6 ++----
 .../java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java  | 7 +++----
 .../java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java   | 7 +++----
 .../main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java   | 7 +++----
 .../src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java    | 5 ++---
 .../java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java   | 7 +++----
 .../apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java    | 7 +++----
 .../src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java   | 5 ++---
 .../org/apache/sqoop/handler/ConnectionRequestHandler.java    | 2 +-
 .../org/apache/sqoop/handler/FrameworkRequestHandler.java     | 2 +-
 .../main/java/org/apache/sqoop/handler/JobRequestHandler.java | 2 +-
 .../org/apache/sqoop/handler/SubmissionRequestHandler.java    | 7 ++++---
 .../integration/connector/jdbc/generic/TableExportTest.java   | 2 +-
 16 files changed, 34 insertions(+), 42 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportDestroyer.java
----------------------------------------------------------------------
diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportDestroyer.java
b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportDestroyer.java
index 60a69e0..2cf07fe 100644
--- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportDestroyer.java
+++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportDestroyer.java
@@ -25,7 +25,8 @@ import org.apache.sqoop.job.etl.DestroyerContext;
 
 public class GenericJdbcImportDestroyer extends Destroyer<ConnectionConfiguration, ImportJobConfiguration>
{
 
-  private static final Logger LOG = Logger.getLogger(GenericJdbcExportDestroyer.class);
+  private static final Logger LOG =
+    Logger.getLogger(GenericJdbcImportDestroyer.class);
 
   @Override
   public void destroy(DestroyerContext context, ConnectionConfiguration connection, ImportJobConfiguration
job) {

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/core/src/main/java/org/apache/sqoop/framework/JobManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/sqoop/framework/JobManager.java b/core/src/main/java/org/apache/sqoop/framework/JobManager.java
index a9645d0..2d37020 100644
--- a/core/src/main/java/org/apache/sqoop/framework/JobManager.java
+++ b/core/src/main/java/org/apache/sqoop/framework/JobManager.java
@@ -46,7 +46,7 @@ public class JobManager implements Reconfigurable {
    /**
     * Logger object.
     */
-   private static final Logger LOG = Logger.getLogger(FrameworkManager.class);
+   private static final Logger LOG = Logger.getLogger(JobManager.class);
 
    /**
     * Private instance to singleton of this class.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/etl/HdfsExportExtractor.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/etl/HdfsExportExtractor.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/etl/HdfsExportExtractor.java
index 9281bb4..1978ec6 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/etl/HdfsExportExtractor.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/etl/HdfsExportExtractor.java
@@ -19,8 +19,6 @@ package org.apache.sqoop.job.etl;
 
 import java.io.IOException;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FSDataInputStream;
 import org.apache.hadoop.fs.FileSystem;
@@ -31,6 +29,7 @@ import org.apache.hadoop.io.Text;
 import org.apache.hadoop.io.compress.CompressionCodec;
 import org.apache.hadoop.io.compress.CompressionCodecFactory;
 import org.apache.hadoop.util.LineReader;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.common.SqoopException;
 import org.apache.sqoop.etl.io.DataWriter;
 import org.apache.sqoop.framework.configuration.ConnectionConfiguration;
@@ -45,7 +44,7 @@ import org.apache.sqoop.job.io.Data;
  */
 public class HdfsExportExtractor extends Extractor<ConnectionConfiguration, ExportJobConfiguration,
HdfsExportPartition> {
 
-  public static final Log LOG = LogFactory.getLog(HdfsExportExtractor.class.getName());
+  public static final Logger LOG = Logger.getLogger(HdfsExportExtractor.class);
 
   private Configuration conf;
   private DataWriter dataWriter;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/ProgressRunnable.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/ProgressRunnable.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/ProgressRunnable.java
index 7e87250..b73b151 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/ProgressRunnable.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/ProgressRunnable.java
@@ -17,10 +17,8 @@
  */
 package org.apache.sqoop.job.mr;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.TaskInputOutputContext;
+import org.apache.log4j.Logger;
 
 
 /**
@@ -28,7 +26,7 @@ import org.apache.hadoop.mapreduce.TaskInputOutputContext;
   */
 public class ProgressRunnable implements Runnable {
 
-  public static final Log LOG = LogFactory.getLog(ProgressRunnable.class);
+  public static final Logger LOG = Logger.getLogger(ProgressRunnable.class);
 
   /**
    * Context class that we should use for reporting progress.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java
index 8cae18e..e1a95a7 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopDestroyerExecutor.java
@@ -17,9 +17,8 @@
  */
 package org.apache.sqoop.job.mr;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.PrefixContext;
 import org.apache.sqoop.job.etl.Destroyer;
@@ -32,8 +31,8 @@ import org.apache.sqoop.utils.ClassUtils;
  */
 public class SqoopDestroyerExecutor {
 
-  public static final Log LOG =
-    LogFactory.getLog(SqoopNullOutputFormat.class.getName());
+  public static final Logger LOG =
+    Logger.getLogger(SqoopDestroyerExecutor.class);
 
   /**
    * Execute destroyer.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java
index 813f370..356ae8a 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopFileOutputFormat.java
@@ -20,8 +20,6 @@ package org.apache.sqoop.job.mr;
 
 import java.io.IOException;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.NullWritable;
@@ -34,6 +32,7 @@ import org.apache.hadoop.mapreduce.RecordWriter;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter;
 import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.io.Data;
 
@@ -43,8 +42,8 @@ import org.apache.sqoop.job.io.Data;
 public class SqoopFileOutputFormat
     extends FileOutputFormat<Data, NullWritable> {
 
-  public static final Log LOG =
-      LogFactory.getLog(SqoopFileOutputFormat.class.getName());
+  public static final Logger LOG =
+    Logger.getLogger(SqoopFileOutputFormat.class);
 
   public static final Class<? extends CompressionCodec> DEFAULT_CODEC =
       DefaultCodec.class;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java
index 3dec782..6891258 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopInputFormat.java
@@ -21,8 +21,6 @@ import java.io.IOException;
 import java.util.LinkedList;
 import java.util.List;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.InputFormat;
@@ -30,6 +28,7 @@ import org.apache.hadoop.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.JobContext;
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.common.SqoopException;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.MapreduceExecutionError;
@@ -45,8 +44,8 @@ import org.apache.sqoop.utils.ClassUtils;
  */
 public class SqoopInputFormat extends InputFormat<SqoopSplit, NullWritable> {
 
-  public static final Log LOG =
-      LogFactory.getLog(SqoopInputFormat.class.getName());
+  public static final Logger LOG =
+    Logger.getLogger(SqoopInputFormat.class);
 
   @Override
   public RecordReader<SqoopSplit, NullWritable> createRecordReader(

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java
index a20d28c..59cf391 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopMapper.java
@@ -22,11 +22,10 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.Mapper;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.common.SqoopException;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.MapreduceExecutionError;
@@ -44,7 +43,7 @@ import org.apache.sqoop.utils.ClassUtils;
  */
 public class SqoopMapper extends Mapper<SqoopSplit, NullWritable, Data, NullWritable>
{
 
-  public static final Log LOG = LogFactory.getLog(SqoopMapper.class);
+  public static final Logger LOG = Logger.getLogger(SqoopMapper.class);
 
   /**
    * Service for reporting progress to mapreduce.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java
index 54604a7..90de6ef 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopNullOutputFormat.java
@@ -18,8 +18,6 @@
 
 package org.apache.sqoop.job.mr;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.JobContext;
@@ -28,6 +26,7 @@ import org.apache.hadoop.mapreduce.OutputCommitter;
 import org.apache.hadoop.mapreduce.OutputFormat;
 import org.apache.hadoop.mapreduce.RecordWriter;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.io.Data;
 
@@ -38,8 +37,8 @@ import java.io.IOException;
  */
 public class SqoopNullOutputFormat extends OutputFormat<Data, NullWritable> {
 
-  public static final Log LOG =
-      LogFactory.getLog(SqoopNullOutputFormat.class.getName());
+  public static final Logger LOG =
+    Logger.getLogger(SqoopNullOutputFormat.class);
 
   @Override
   public void checkOutputSpecs(JobContext context) {

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
index 9232b76..739eb17 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java
@@ -24,13 +24,12 @@ import java.io.IOException;
 import java.util.concurrent.*;
 
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.JobContext;
 import org.apache.hadoop.mapreduce.RecordWriter;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.common.SqoopException;
 import org.apache.sqoop.job.JobConstants;
 import org.apache.sqoop.job.MapreduceExecutionError;
@@ -44,8 +43,8 @@ import org.apache.sqoop.utils.ClassUtils;
 
 public class SqoopOutputFormatLoadExecutor {
 
-  public static final Log LOG =
-      LogFactory.getLog(SqoopOutputFormatLoadExecutor.class.getName());
+  public static final Logger LOG =
+    Logger.getLogger(SqoopOutputFormatLoadExecutor.class);
 
   private volatile boolean readerFinished = false;
   private volatile boolean writerFinished = false;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java
----------------------------------------------------------------------
diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java
index e4ad6ba..b31161c 100644
--- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java
+++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopReducer.java
@@ -17,10 +17,9 @@
  */
 package org.apache.sqoop.job.mr;
 
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.Reducer;
+import org.apache.log4j.Logger;
 import org.apache.sqoop.job.io.Data;
 
 import java.io.IOException;
@@ -33,7 +32,7 @@ import java.util.concurrent.TimeUnit;
  */
 public class SqoopReducer extends Reducer<Data, NullWritable, Data, NullWritable> {
 
-  public static final Log LOG = LogFactory.getLog(SqoopReducer.class);
+  public static final Logger LOG = Logger.getLogger(SqoopReducer.class);
 
   /**
    * Service for reporting progress to mapreduce.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/server/src/main/java/org/apache/sqoop/handler/ConnectionRequestHandler.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/sqoop/handler/ConnectionRequestHandler.java b/server/src/main/java/org/apache/sqoop/handler/ConnectionRequestHandler.java
index 7842e32..038f602 100644
--- a/server/src/main/java/org/apache/sqoop/handler/ConnectionRequestHandler.java
+++ b/server/src/main/java/org/apache/sqoop/handler/ConnectionRequestHandler.java
@@ -69,7 +69,7 @@ import java.util.Locale;
 public class ConnectionRequestHandler implements RequestHandler {
 
   private static final Logger LOG =
-      Logger.getLogger(ConnectorRequestHandler.class);
+      Logger.getLogger(ConnectionRequestHandler.class);
 
   public ConnectionRequestHandler() {
     LOG.info("ConnectionRequestHandler initialized");

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/server/src/main/java/org/apache/sqoop/handler/FrameworkRequestHandler.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/sqoop/handler/FrameworkRequestHandler.java b/server/src/main/java/org/apache/sqoop/handler/FrameworkRequestHandler.java
index 48fe0ff..04ffc3c 100644
--- a/server/src/main/java/org/apache/sqoop/handler/FrameworkRequestHandler.java
+++ b/server/src/main/java/org/apache/sqoop/handler/FrameworkRequestHandler.java
@@ -34,7 +34,7 @@ import org.apache.sqoop.server.RequestHandler;
 public class FrameworkRequestHandler  implements RequestHandler {
 
   private static final Logger LOG =
-      Logger.getLogger(ConnectorRequestHandler.class);
+      Logger.getLogger(FrameworkRequestHandler.class);
 
   public FrameworkRequestHandler() {
     LOG.info("FrameworkRequestHandler initialized");

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/server/src/main/java/org/apache/sqoop/handler/JobRequestHandler.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/sqoop/handler/JobRequestHandler.java b/server/src/main/java/org/apache/sqoop/handler/JobRequestHandler.java
index 18b9997..ab3f9d0 100644
--- a/server/src/main/java/org/apache/sqoop/handler/JobRequestHandler.java
+++ b/server/src/main/java/org/apache/sqoop/handler/JobRequestHandler.java
@@ -69,7 +69,7 @@ import java.util.Locale;
 public class JobRequestHandler implements RequestHandler {
 
   private static final Logger LOG =
-      Logger.getLogger(ConnectorRequestHandler.class);
+      Logger.getLogger(JobRequestHandler.class);
 
   public JobRequestHandler() {
     LOG.info("JobRequestHandler initialized");

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java b/server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java
index 1f7a208..65686a8 100644
--- a/server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java
+++ b/server/src/main/java/org/apache/sqoop/handler/SubmissionRequestHandler.java
@@ -50,10 +50,11 @@ import org.apache.sqoop.server.common.ServerError;
  */
 public class SubmissionRequestHandler implements RequestHandler {
 
-  private final Logger logger = Logger.getLogger(getClass());
+  private static final Logger LOG =
+    Logger.getLogger(SubmissionRequestHandler.class);
 
   public SubmissionRequestHandler() {
-    logger.info("SubmissionRequestHandler initialized");
+    LOG.info("SubmissionRequestHandler initialized");
   }
 
   @Override
@@ -85,7 +86,7 @@ public class SubmissionRequestHandler implements RequestHandler {
   }
 
   private JsonBean handleNotification(RequestContext ctx, String sjid) {
-    logger.debug("Received notification request for job " + sjid);
+    LOG.debug("Received notification request for job " + sjid);
     JobManager.getInstance().status(Long.parseLong(sjid));
     return JsonBean.EMPTY_BEAN;
   }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/1f016abb/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/TableExportTest.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/TableExportTest.java
b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/TableExportTest.java
index fbf46e9..b36cb07 100644
--- a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/TableExportTest.java
+++ b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/TableExportTest.java
@@ -33,7 +33,7 @@ import static org.junit.Assert.assertTrue;
  */
 public class TableExportTest extends ConnectorTestCase {
 
-  private static final Logger LOG = Logger.getLogger(TableImportTest.class);
+  private static final Logger LOG = Logger.getLogger(TableExportTest.class);
 
   @Test
   public void testBasicImport() throws Exception {


Mime
View raw message