File tree Expand file tree Collapse file tree 1 file changed +1
-4
lines changed
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver Expand file tree Collapse file tree 1 file changed +1
-4
lines changed Original file line number Diff line number Diff line change 18
18
package org .apache .hadoop .hbase .replication .regionserver ;
19
19
20
20
import static org .junit .Assert .assertEquals ;
21
-
22
21
import java .io .IOException ;
23
22
import java .util .ArrayList ;
24
23
import java .util .Collections ;
72
71
import org .junit .experimental .categories .Category ;
73
72
import org .slf4j .Logger ;
74
73
import org .slf4j .LoggerFactory ;
75
-
76
74
import org .apache .hbase .thirdparty .com .google .protobuf .UnsafeByteOperations ;
77
-
78
75
import org .apache .hadoop .hbase .shaded .protobuf .ProtobufUtil ;
79
76
import org .apache .hadoop .hbase .shaded .protobuf .generated .AdminProtos .WALEntry ;
80
77
import org .apache .hadoop .hbase .shaded .protobuf .generated .HBaseProtos .UUID ;
@@ -135,7 +132,7 @@ public static void setUpBeforeClass() throws Exception {
135
132
TEST_UTIL .getConfiguration ().set ("hbase.replication.source.fs.conf.provider" ,
136
133
TestSourceFSConfigurationProvider .class .getCanonicalName ());
137
134
TEST_UTIL .getConfiguration ().setClass (HConstants .REPLICATION_SINK_TRANSLATOR ,
138
- IdentityReplicationSinkTranslator .class , ReplicationSinkTranslator .class );
135
+ TestReplicationSinkTranslator .class , ReplicationSinkTranslator .class );
139
136
TEST_UTIL .startMiniCluster (3 );
140
137
RegionServerCoprocessorHost rsCpHost =
141
138
TEST_UTIL .getMiniHBaseCluster ().getRegionServer (0 ).getRegionServerCoprocessorHost ();
You can’t perform that action at this time.
0 commit comments