Skip to content

Commit 81f38a7

Browse files
committed
fix test and address checkstyle warning
1 parent 229197e commit 81f38a7

File tree

2 files changed

+9
-20
lines changed

2 files changed

+9
-20
lines changed

hbase-server/src/test/java/org/apache/hadoop/hbase/codec/CodecPerformance.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
package org.apache.hadoop.hbase.codec;
1919

2020
import static org.junit.Assert.assertArrayEquals;
21-
import static org.junit.Assert.assertEquals;
2221
import static org.junit.Assert.assertTrue;
2322

2423
import java.io.ByteArrayInputStream;
@@ -31,10 +30,6 @@
3130
import org.apache.hadoop.hbase.Cell;
3231
import org.apache.hadoop.hbase.CellScanner;
3332
import org.apache.hadoop.hbase.KeyValue;
34-
import org.apache.hadoop.hbase.codec.CellCodec;
35-
import org.apache.hadoop.hbase.codec.Codec;
36-
import org.apache.hadoop.hbase.codec.KeyValueCodec;
37-
import org.apache.hadoop.hbase.codec.MessageCodec;
3833
import org.apache.hadoop.hbase.io.CellOutputStream;
3934
import org.apache.hadoop.hbase.util.Bytes;
4035
import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;

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

Lines changed: 9 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -18,15 +18,18 @@
1818
package org.apache.hadoop.hbase.regionserver;
1919

2020
import static org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerFactory.TRACKER_IMPL;
21+
import static org.hamcrest.MatcherAssert.assertThat;
22+
import static org.hamcrest.Matchers.containsString;
23+
import static org.hamcrest.Matchers.everyItem;
24+
import static org.hamcrest.Matchers.hasItem;
25+
import static org.hamcrest.Matchers.hasProperty;
26+
import static org.hamcrest.Matchers.not;
2127
import static org.junit.Assert.assertTrue;
22-
import static org.junit.Assert.fail;
23-
2428
import java.io.IOException;
2529
import java.util.ArrayList;
2630
import java.util.List;
2731
import java.util.UUID;
2832
import java.util.concurrent.TimeUnit;
29-
import org.apache.commons.lang3.mutable.MutableBoolean;
3033
import org.apache.hadoop.fs.FileStatus;
3134
import org.apache.hadoop.fs.FileSystem;
3235
import org.apache.hadoop.fs.FileUtil;
@@ -222,21 +225,12 @@ private Pair<StoreFileInfo,String> copyFileInTheStoreDir(HRegion region) throws
222225
return new Pair<>(fileInfo, copyName);
223226
}
224227

225-
private void validateDaughterRegionsFiles(HRegion region, String orignalFileName,
228+
private void validateDaughterRegionsFiles(HRegion region, String originalFileName,
226229
String untrackedFile) throws IOException {
227230
//verify there's no link for the untracked, copied file in first region
228231
List<StoreFileInfo> infos = region.getRegionFileSystem().getStoreFiles("info");
229-
final MutableBoolean foundLink = new MutableBoolean(false);
230-
infos.stream().forEach(i -> {
231-
assertTrue(i.getActiveFileName().contains(orignalFileName));
232-
if(i.getActiveFileName().contains(untrackedFile)){
233-
fail();
234-
}
235-
if(i.getActiveFileName().contains(orignalFileName)){
236-
foundLink.setTrue();
237-
}
238-
});
239-
assertTrue(foundLink.booleanValue());
232+
assertThat(infos, everyItem(hasProperty("activeFileName", not(containsString(untrackedFile)))));
233+
assertThat(infos, hasItem(hasProperty("activeFileName", containsString(originalFileName))));
240234
}
241235

242236
private void verifyFilesAreTracked(Path regionDir, FileSystem fs) throws Exception {

0 commit comments

Comments
 (0)