HBASE-30126 Fix mismatched LoggerFactory class references (#8152)

hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java

@@ -379,7 +379,7 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
 
   public static final String FLUSH_TABLE_PROCEDURE_SIGNATURE = "flush-table-proc";
 
-  private static final Logger LOG = LoggerFactory.getLogger(AsyncHBaseAdmin.class);
+  private static final Logger LOG = LoggerFactory.getLogger(RawAsyncHBaseAdmin.class);
 
   private final AsyncConnectionImpl connection;
 

hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/ReusableStreamGzipCodec.java

@@ -37,7 +37,7 @@
 @InterfaceAudience.Private
 public class ReusableStreamGzipCodec extends GzipCodec {
 
-  private static final Logger LOG = LoggerFactory.getLogger(Compression.class);
+  private static final Logger LOG = LoggerFactory.getLogger(ReusableStreamGzipCodec.class);
 
   /**
    * A bridge that wraps around a DeflaterOutputStream to make it a CompressionOutputStream.

hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/CompatibilityFactory.java

@@ -29,7 +29,7 @@
 @InterfaceAudience.Private
 public class CompatibilityFactory {
 
-  private static final Logger LOG = LoggerFactory.getLogger(CompatibilitySingletonFactory.class);
+  private static final Logger LOG = LoggerFactory.getLogger(CompatibilityFactory.class);
   public static final String EXCEPTION_START = "Could not create  ";
   public static final String EXCEPTION_END = " Is the hadoop compatibility jar on the classpath?";
 

hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestGlobalFilter.java

@@ -42,7 +42,7 @@
 @Tag(SmallTests.TAG)
 public class TestGlobalFilter extends HttpServerFunctionalTest {
 
-  private static final Logger LOG = LoggerFactory.getLogger(HttpServer.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestGlobalFilter.class);
   private static final Set<String> RECORDS = new TreeSet<>();
 
   /** A very simple filter that records accessed uri's */

hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestPathFilter.java

@@ -42,7 +42,7 @@
 @Tag(SmallTests.TAG)
 public class TestPathFilter extends HttpServerFunctionalTest {
 
-  private static final Logger LOG = LoggerFactory.getLogger(HttpServer.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestPathFilter.class);
   private static final Set<String> RECORDS = new TreeSet<>();
 
   /** A very simple filter that records accessed uri's */

hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestServletFilter.java

@@ -47,7 +47,7 @@
 @Tag(SmallTests.TAG)
 public class TestServletFilter extends HttpServerFunctionalTest {
 
-  private static final Logger LOG = LoggerFactory.getLogger(HttpServer.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestServletFilter.class);
   private static volatile String uri = null;
 
   /** A very simple filter which record the uri filtered. */

hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java

@@ -189,7 +189,7 @@ protected void reduce(CellWritableComparable row, Iterable<Cell> kvs,
   public static class CellSortImporter extends TableMapper<CellWritableComparable, Cell> {
     private Map<byte[], byte[]> cfRenameMap;
     private Filter filter;
-    private static final Logger LOG = LoggerFactory.getLogger(CellImporter.class);
+    private static final Logger LOG = LoggerFactory.getLogger(CellSortImporter.class);
 
     /**
      * @param row     The current table row key.

hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/MultiTableInputFormatTestBase.java

@@ -55,7 +55,7 @@
  * Base set of tests and setup for input formats touching multiple tables.
  */
 public abstract class MultiTableInputFormatTestBase {
-  static final Logger LOG = LoggerFactory.getLogger(TestMultiTableInputFormat.class);
+  static final Logger LOG = LoggerFactory.getLogger(MultiTableInputFormatTestBase.class);
   public static final HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
   static final String TABLE_NAME = "scantest";
   static final byte[] INPUT_FAMILY = Bytes.toBytes("contents");

hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricRegistriesLoader.java

@@ -27,7 +27,7 @@
 
 @InterfaceAudience.Private
 public final class MetricRegistriesLoader {
-  private static final Logger LOG = LoggerFactory.getLogger(MetricRegistries.class);
+  private static final Logger LOG = LoggerFactory.getLogger(MetricRegistriesLoader.class);
 
   private static final String defaultClass =
     "org.apache.hadoop.hbase.metrics.impl.MetricRegistriesImpl";

hbase-server/src/main/java/org/apache/hadoop/hbase/ExecutorStatusChore.java

@@ -36,7 +36,7 @@
  */
 @InterfaceAudience.Private
 public class ExecutorStatusChore extends ScheduledChore {
-  private static final Logger LOG = LoggerFactory.getLogger(HealthCheckChore.class);
+  private static final Logger LOG = LoggerFactory.getLogger(ExecutorStatusChore.class);
   public static final String WAKE_FREQ = "hbase.executors.status.collect.period";
   public static final int DEFAULT_WAKE_FREQ = 60000;
   private ExecutorService service;

hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZKSplitLogManagerCoordination.java

@@ -68,7 +68,7 @@ public class ZKSplitLogManagerCoordination extends ZKListener
   public static final int DEFAULT_ZK_RETRIES = 3;
   public static final int DEFAULT_MAX_RESUBMIT = 3;
 
-  private static final Logger LOG = LoggerFactory.getLogger(SplitLogManagerCoordination.class);
+  private static final Logger LOG = LoggerFactory.getLogger(ZKSplitLogManagerCoordination.class);
 
   private final TaskFinisher taskFinisher;
   private final Configuration conf;

hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java

@@ -102,7 +102,7 @@
 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
 @InterfaceStability.Evolving
 public class MultiRowMutationEndpoint extends MultiRowMutationService implements RegionCoprocessor {
-  private static final Logger LOGGER = LoggerFactory.getLogger(HRegion.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(MultiRowMutationEndpoint.class);
 
   private RegionCoprocessorEnvironment env;
 

hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePreadReader.java

@@ -30,7 +30,7 @@
  */
 @InterfaceAudience.Private
 public class HFilePreadReader extends HFileReaderImpl {
-  private static final Logger LOG = LoggerFactory.getLogger(HFileReaderImpl.class);
+  private static final Logger LOG = LoggerFactory.getLogger(HFilePreadReader.class);
 
   private static final int WAIT_TIME_FOR_CACHE_INITIALIZATION = 10 * 60 * 1000;
 

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceLogQueue.java

@@ -37,7 +37,7 @@
 @InterfaceAudience.Private
 @InterfaceStability.Evolving
 public class ReplicationSourceLogQueue {
-  private static final Logger LOG = LoggerFactory.getLogger(ReplicationSource.class);
+  private static final Logger LOG = LoggerFactory.getLogger(ReplicationSourceLogQueue.class);
   // Queues of logs to process, entry in format of walGroupId->queue,
   // each presents a queue for one wal group
   private Map<String, PriorityBlockingQueue<Path>> queues = new ConcurrentHashMap<>();

hbase-server/src/main/java/org/apache/hadoop/hbase/security/provider/SaslServerAuthenticationProviders.java

@@ -34,7 +34,7 @@
 @InterfaceAudience.Private
 public final class SaslServerAuthenticationProviders {
   private static final Logger LOG =
-    LoggerFactory.getLogger(SaslClientAuthenticationProviders.class);
+    LoggerFactory.getLogger(SaslServerAuthenticationProviders.class);
 
   public static final String EXTRA_PROVIDERS_KEY = "hbase.server.sasl.provider.extras";
 

hbase-server/src/main/java/org/apache/hadoop/hbase/tool/CanaryTool.java

@@ -798,7 +798,7 @@ public Void call() {
   private static final long DEFAULT_TIMEOUT = 600000; // 10 mins
   private static final int MAX_THREADS_NUM = 16; // #threads to contact regions
 
-  private static final Logger LOG = LoggerFactory.getLogger(Canary.class);
+  private static final Logger LOG = LoggerFactory.getLogger(CanaryTool.class);
 
   public static final TableName DEFAULT_WRITE_TABLE_NAME =
     TableName.valueOf(NamespaceDescriptor.SYSTEM_NAMESPACE_NAME_STR, "canary");

hbase-server/src/main/java/org/apache/hadoop/hbase/wal/AbstractRecoveredEditsOutputSink.java

@@ -46,7 +46,7 @@
 
 @InterfaceAudience.Private
 abstract class AbstractRecoveredEditsOutputSink extends OutputSink {
-  private static final Logger LOG = LoggerFactory.getLogger(RecoveredEditsOutputSink.class);
+  private static final Logger LOG = LoggerFactory.getLogger(AbstractRecoveredEditsOutputSink.class);
   private final WALSplitter walSplitter;
   private final ConcurrentMap<String, Long> regionMaximumEditLogSeqNum = new ConcurrentHashMap<>();
   private static final int MAX_RENAME_RETRY_COUNT = 5;

hbase-server/src/test/java/org/apache/hadoop/hbase/client/BasicReadWriteWithDifferentConnectionRegistriesTestBase.java

@@ -38,7 +38,7 @@
 public abstract class BasicReadWriteWithDifferentConnectionRegistriesTestBase {
 
   private static final Logger LOG =
-    LoggerFactory.getLogger(TestBasicReadWriteWithDifferentConnectionRegistries.class);
+    LoggerFactory.getLogger(BasicReadWriteWithDifferentConnectionRegistriesTestBase.class);
 
   protected static final HBaseTestingUtil UTIL = new HBaseTestingUtil();
 

hbase-server/src/test/java/org/apache/hadoop/hbase/master/AbstractTestDLS.java

@@ -84,7 +84,7 @@
  * Base class for testing distributed log splitting.
  */
 public abstract class AbstractTestDLS {
-  private static final Logger LOG = LoggerFactory.getLogger(TestSplitLogManager.class);
+  private static final Logger LOG = LoggerFactory.getLogger(AbstractTestDLS.class);
 
   private static final HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
 

hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterOperationsForRegionReplicas.java

@@ -75,7 +75,8 @@
 @Tag(MediumTests.TAG)
 public class TestMasterOperationsForRegionReplicas {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestRegionPlacement.class);
+  private static final Logger LOG =
+    LoggerFactory.getLogger(TestMasterOperationsForRegionReplicas.class);
   private final static HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
   private static Connection CONNECTION = null;
   private static Admin ADMIN;

hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestMasterProcedureEvents.java

@@ -52,7 +52,7 @@
 @Tag(MediumTests.TAG)
 public class TestMasterProcedureEvents {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestCreateTableProcedure.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestMasterProcedureEvents.class);
 
   protected static final HBaseTestingUtil UTIL = new HBaseTestingUtil();
   private String testMethodName;

hbase-server/src/test/java/org/apache/hadoop/hbase/namequeues/TestWALEventTracker.java

@@ -62,7 +62,7 @@
 @Tag(RegionServerTests.TAG)
 public class TestWALEventTracker {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestNamedQueueRecorder.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestWALEventTracker.class);
   private static HBaseTestingUtil TEST_UTIL;
   public static Configuration CONF;
 

hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionReplayEvents.java

@@ -121,7 +121,7 @@ public class TestHRegionReplayEvents {
   public static final HBaseClassTestRule CLASS_RULE =
     HBaseClassTestRule.forClass(TestHRegionReplayEvents.class);
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestHRegion.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestHRegionReplayEvents.class);
   @Rule
   public TestName name = new TestName();
 

hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionReplicaFailover.java

@@ -38,7 +38,6 @@
 import org.apache.hadoop.hbase.client.Get;
 import org.apache.hadoop.hbase.client.Table;
 import org.apache.hadoop.hbase.client.TableDescriptor;
-import org.apache.hadoop.hbase.replication.regionserver.TestRegionReplicaReplication;
 import org.apache.hadoop.hbase.testclassification.LargeTests;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread;
@@ -63,7 +62,7 @@ public class TestRegionReplicaFailover {
   public static final HBaseClassTestRule CLASS_RULE =
     HBaseClassTestRule.forClass(TestRegionReplicaFailover.class);
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestRegionReplicaReplication.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestRegionReplicaFailover.class);
 
   private static final HBaseTestingUtil HTU = new HBaseTestingUtil();
 

hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRollAbort.java

@@ -88,7 +88,7 @@ public class TestLogRollAbort {
   public static final HBaseClassTestRule CLASS_RULE =
     HBaseClassTestRule.forClass(TestLogRollAbort.class);
 
-  private static final Logger LOG = LoggerFactory.getLogger(AbstractTestLogRolling.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestLogRollAbort.class);
   private static MiniDFSCluster dfsCluster;
   private static Admin admin;
   private static SingleProcessHBaseCluster cluster;

hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStuckWithDroppedTable.java

@@ -57,7 +57,7 @@ public class TestReplicationStuckWithDroppedTable {
     HBaseClassTestRule.forClass(TestReplicationStuckWithDroppedTable.class);
 
   private static final Logger LOG =
-    LoggerFactory.getLogger(TestReplicationEditsDroppedWithDroppedTable.class);
+    LoggerFactory.getLogger(TestReplicationStuckWithDroppedTable.class);
 
   private static Configuration conf1 = HBaseConfiguration.create();
   private static Configuration conf2 = HBaseConfiguration.create();

hbase-server/src/test/java/org/apache/hadoop/hbase/rsgroup/EnableRSGroupsTestBase.java

@@ -33,7 +33,7 @@
 
 public abstract class EnableRSGroupsTestBase {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestEnableRSGroupsCompatibility.class);
+  private static final Logger LOG = LoggerFactory.getLogger(EnableRSGroupsTestBase.class);
 
   private static final HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
 

hbase-server/src/test/java/org/apache/hadoop/hbase/security/access/TestAccessController3.java

@@ -62,7 +62,7 @@
 @Tag(MediumTests.TAG)
 public class TestAccessController3 extends SecureTestUtil {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestAccessController.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestAccessController3.class);
   private static TableName TEST_TABLE = TableName.valueOf("testtable1");
   private static final HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
   private static Configuration conf;

hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestConcurrentFlushSnapshotFromClient.java

@@ -29,7 +29,8 @@
 @Tag(ClientTests.TAG)
 @Tag(LargeTests.TAG)
 public class TestConcurrentFlushSnapshotFromClient extends TestFlushSnapshotFromClient {
-  private static final Logger LOG = LoggerFactory.getLogger(TestFlushSnapshotFromClient.class);
+  private static final Logger LOG =
+    LoggerFactory.getLogger(TestConcurrentFlushSnapshotFromClient.class);
 
   @BeforeAll
   public static void setupCluster() throws Exception {

hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestMobFlushSnapshotFromClient.java

@@ -41,7 +41,7 @@
 @Tag(LargeTests.TAG)
 public class TestMobFlushSnapshotFromClient extends TestFlushSnapshotFromClient {
 
-  private static final Logger LOG = LoggerFactory.getLogger(TestFlushSnapshotFromClient.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestMobFlushSnapshotFromClient.class);
 
   @BeforeAll
   public static void setupCluster() throws Exception {

hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestSnapshotWhenChoreCleaning.java

@@ -58,7 +58,7 @@ public class TestSnapshotWhenChoreCleaning {
 
   private static final HBaseTestingUtil TEST_UTIL = new HBaseTestingUtil();
   private static final Configuration CONF = TEST_UTIL.getConfiguration();
-  private static final Logger LOG = LoggerFactory.getLogger(TestSnapshotClientRetries.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestSnapshotWhenChoreCleaning.class);
   private static final TableName TABLE_NAME = TableName.valueOf("testTable");
   private static final int MAX_SPLIT_KEYS_NUM = 100;
   private static final byte[] FAMILY = Bytes.toBytes("family");

hbase-server/src/test/java/org/apache/hadoop/hbase/wal/TestWALSplitToHFile.java

@@ -87,7 +87,7 @@
 @Tag(MediumTests.TAG)
 public class TestWALSplitToHFile {
 
-  private static final Logger LOG = LoggerFactory.getLogger(AbstractTestWALReplay.class);
+  private static final Logger LOG = LoggerFactory.getLogger(TestWALSplitToHFile.class);
   static final HBaseTestingUtil UTIL = new HBaseTestingUtil();
   private final EnvironmentEdge ee = EnvironmentEdgeManager.getDelegate();
   private Path rootDir = null;

hbase-server/src/test/java/org/apache/hadoop/hbase/wal/WALCorruptionDueToDanglingByteBufferTestBase.java

@@ -39,7 +39,7 @@
 public abstract class WALCorruptionDueToDanglingByteBufferTestBase {
 
   private static final Logger LOG =
-    LoggerFactory.getLogger(TestAsyncFSWALCorruptionDueToDanglingByteBuffer.class);
+    LoggerFactory.getLogger(WALCorruptionDueToDanglingByteBufferTestBase.class);
 
   protected static final HBaseTestingUtil UTIL = new HBaseTestingUtil();
 

hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/HThreadedSelectorServerArgs.java

@@ -30,7 +30,7 @@
  */
 @InterfaceAudience.Private
 public class HThreadedSelectorServerArgs extends TThreadedSelectorServer.Args {
-  private static final Logger LOG = LoggerFactory.getLogger(TThreadedSelectorServer.class);
+  private static final Logger LOG = LoggerFactory.getLogger(HThreadedSelectorServerArgs.class);
 
   /**
    * Number of selector threads for reading and writing socket