Fix test for tableName translation

apache · Jan 7, 2025 · 0ad9568 · 0ad9568
1 parent 6851274
commit 0ad9568
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...r/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSink.java b/...r/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSink.java
@@ -18,7 +18,6 @@
 package org.apache.hadoop.hbase.replication.regionserver;
 
 import static org.junit.Assert.assertEquals;
-
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Collections;
@@ -72,9 +71,7 @@
 import org.junit.experimental.categories.Category;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations;
-
 import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
 import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry;
 import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.UUID;
@@ -135,7 +132,7 @@ public static void setUpBeforeClass() throws Exception {
     TEST_UTIL.getConfiguration().set("hbase.replication.source.fs.conf.provider",
       TestSourceFSConfigurationProvider.class.getCanonicalName());
     TEST_UTIL.getConfiguration().setClass(HConstants.REPLICATION_SINK_TRANSLATOR,
-      IdentityReplicationSinkTranslator.class, ReplicationSinkTranslator.class);
+      TestReplicationSinkTranslator.class, ReplicationSinkTranslator.class);
     TEST_UTIL.startMiniCluster(3);
     RegionServerCoprocessorHost rsCpHost =
       TEST_UTIL.getMiniHBaseCluster().getRegionServer(0).getRegionServerCoprocessorHost();