Skip to content

Commit 204a058

Browse files
author
niuyulin
committed
fix ut and style
1 parent 2e3f6df commit 204a058

2 files changed

Lines changed: 10 additions & 5 deletions

File tree

hbase-server/src/main/java/org/apache/hadoop/hbase/compactionserver/CSRpcServices.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919

2020
import java.io.IOException;
2121
import java.util.ArrayList;
22-
import java.util.Collections;
2322
import java.util.List;
2423

2524
import org.apache.hadoop.conf.Configuration;
@@ -42,7 +41,6 @@
4241
import org.apache.hadoop.hbase.shaded.protobuf.generated.CompactionProtos;
4342
import org.apache.hadoop.hbase.shaded.protobuf.generated.CompactionProtos.CompactResponse;
4443
import org.apache.hadoop.hbase.shaded.protobuf.generated.CompactionProtos.CompactionService;
45-
import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos;
4644

4745
@InterfaceAudience.Private
4846
public class CSRpcServices extends AbstractRpcServices

hbase-server/src/test/java/org/apache/hadoop/hbase/compactionserver/TestRegionFavoredNodesWhenCompactOffload.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,11 @@
1616
* limitations under the License.
1717
*/
1818
package org.apache.hadoop.hbase.compactionserver;
19+
20+
import java.net.InetSocketAddress;
21+
22+
import org.apache.hadoop.hbase.HBaseClassTestRule;
23+
import org.apache.hadoop.hbase.HBaseTestingUtility;
1924
import org.apache.hadoop.hbase.StartMiniClusterOption;
2025
import org.apache.hadoop.hbase.client.TableDescriptor;
2126
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
@@ -26,17 +31,19 @@
2631
import org.apache.hadoop.hbase.util.Bytes;
2732
import org.junit.Assume;
2833
import org.junit.BeforeClass;
34+
import org.junit.ClassRule;
2935
import org.junit.Test;
3036
import org.junit.experimental.categories.Category;
31-
import org.apache.hadoop.hbase.HBaseTestingUtility;
32-
33-
import java.net.InetSocketAddress;
3437

3538
@Category({ CompactionServerTests.class, MediumTests.class })
3639
public class TestRegionFavoredNodesWhenCompactOffload extends TestRegionFavoredNodes {
3740
private static HCompactionServer COMPACTION_SERVER;
3841
private static final int FLUSHES = 10;
3942

43+
@ClassRule
44+
public static final HBaseClassTestRule CLASS_RULE =
45+
HBaseClassTestRule.forClass(TestRegionFavoredNodesWhenCompactOffload.class);
46+
4047
@BeforeClass
4148
public static void setUpBeforeClass() throws Exception {
4249
try {

0 commit comments

Comments
 (0)