Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25127 Enhance PerformanceEvaluation to profile meta replica performance. (#2655) 

* HBASE-25127 Enhance PerformanceEvaluation to profile meta replica performance. (#2644)


Signed-off-by: Duo Zhang <zhangduo@apache.org>
Signed-off-by: Huaxiang Sun <huaxiangsun@apache.com>
Signed-off-by: stack <stack@apache.com>
This commit is contained in:
clarax 2020-11-30 22:51:57 -08:00 committed by GitHub
parent f0a4aefcdf
commit 4c8fa47b28
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 139 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
View File

@ -1306,7 +1306,7 @@ public class MetaTableAccessor {
/**
* Generates and returns a Delete containing the region info for the catalog table
*/
private static Delete makeDeleteFromRegionInfo(RegionInfo regionInfo, long ts) {
public static Delete makeDeleteFromRegionInfo(RegionInfo regionInfo, long ts) {
if (regionInfo == null) {
throw new IllegalArgumentException("Can't make a delete for null region");
}

136
hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
View File

@ -31,6 +31,7 @@ import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.NoSuchElementException;
@ -61,6 +62,9 @@ import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Increment;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.RegionInfo;
import org.apache.hadoop.hbase.client.RegionInfoBuilder;
import org.apache.hadoop.hbase.client.RegionLocator;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.RowMutations;
@ -166,8 +170,9 @@ public class PerformanceEvaluation extends Configured implements Tool {
"Run async sequential write test");
addCommandDescriptor(AsyncScanTest.class, "asyncScan",
"Run async scan test (read every row)");
addCommandDescriptor(RandomReadTest.class, RANDOM_READ,
"Run random read test");
addCommandDescriptor(RandomReadTest.class, RANDOM_READ, "Run random read test");
addCommandDescriptor(MetaRandomReadTest.class, "metaRandomRead",
"Run getRegionLocation test");
addCommandDescriptor(RandomSeekScanTest.class, RANDOM_SEEK_SCAN,
"Run random seek and scan 100 test");
addCommandDescriptor(RandomScanWithRange10Test.class, "scanRange10",
@ -184,8 +189,9 @@ public class PerformanceEvaluation extends Configured implements Tool {
"Run sequential read test");
addCommandDescriptor(SequentialWriteTest.class, "sequentialWrite",
"Run sequential write test");
addCommandDescriptor(ScanTest.class, "scan",
"Run scan test (read every row)");
addCommandDescriptor(MetaWriteTest.class, "metaWrite",
"Populate meta table;used with 1 thread; to be cleaned up by cleanMeta");
addCommandDescriptor(ScanTest.class, "scan", "Run scan test (read every row)");
addCommandDescriptor(FilteredScanTest.class, "filterScan",
"Run scan test using a filter to find a specific row based on it's value " +
"(make sure to use --rows=20)");
@ -199,6 +205,8 @@ public class PerformanceEvaluation extends Configured implements Tool {
"CheckAndPut on each row; clients overlap on keyspace so some concurrent operations");
addCommandDescriptor(CheckAndDeleteTest.class, "checkAndDelete",
"CheckAndDelete on each row; clients overlap on keyspace so some concurrent operations");
addCommandDescriptor(CleanMetaTest.class, "cleanMeta",
"Remove fake region entries on meta table inserted by metaWrite; used with 1 thread");
}
/**
@ -1471,6 +1479,31 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
}
/*
Parent class for all meta tests: MetaWriteTest, MetaRandomReadTest and CleanMetaTest
*/
static abstract class MetaTest extends TableTest {
protected int keyLength;
MetaTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
keyLength = Integer.toString(opts.perClientRunRows).length();
}
@Override
void onTakedown() throws IOException {
// No clean up
}
/*
Generates Lexicographically ascending strings
*/
protected byte[] getSplitKey(final int i) {
return Bytes.toBytes(String.format("%0" + keyLength + "d", i));
}
}
static abstract class AsyncTableTest extends AsyncTest {
protected AsyncTable<?> table;
@ -1989,6 +2022,47 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
}
/*
Send random reads against fake regions inserted by MetaWriteTest
*/
static class MetaRandomReadTest extends MetaTest {
private Random rd = new Random();
private RegionLocator regionLocator;
MetaRandomReadTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
LOG.info("call getRegionLocation");
}
@Override
void onStartup() throws IOException {
super.onStartup();
this.regionLocator = connection.getRegionLocator(table.getName());
}
@Override
boolean testRow(final int i, final long startTime) throws IOException, InterruptedException {
if (opts.randomSleep > 0) {
Thread.sleep(rd.nextInt(opts.randomSleep));
}
HRegionLocation hRegionLocation = regionLocator.getRegionLocation(
getSplitKey(rd.nextInt(opts.perClientRunRows)), true);
LOG.debug("get location for region: " + hRegionLocation);
return true;
}
@Override
protected int getReportingPeriod() {
int period = opts.perClientRunRows / 10;
return period == 0 ? opts.perClientRunRows : period;
}
@Override
protected void testTakedown() throws IOException {
super.testTakedown();
}
}
static class RandomWriteTest extends SequentialWriteTest {
RandomWriteTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
@ -2178,6 +2252,34 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
}
/*
Delete all fake regions inserted to meta table by MetaWriteTest.
*/
static class CleanMetaTest extends MetaTest {
CleanMetaTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
}
@Override
boolean testRow(final int i, final long startTime) throws IOException {
try {
RegionInfo regionInfo = connection.getRegionLocator(table.getName())
.getRegionLocation(getSplitKey(i), false).getRegion();
LOG.debug("deleting region from meta: " + regionInfo);
Delete delete = MetaTableAccessor
.makeDeleteFromRegionInfo(regionInfo, HConstants.LATEST_TIMESTAMP);
try (Table t = MetaTableAccessor.getMetaHTable(connection)) {
t.delete(delete);
}
} catch (IOException ie) {
// Log and continue
LOG.error("cannot find region with start key: " + i);
}
return true;
}
}
static class SequentialReadTest extends TableTest {
SequentialReadTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
@ -2267,6 +2369,32 @@ public class PerformanceEvaluation extends Configured implements Tool {
}
}
/*
Insert fake regions into meta table with contiguous split keys.
*/
static class MetaWriteTest extends MetaTest {
MetaWriteTest(Connection con, TestOptions options, Status status) {
super(con, options, status);
}
@Override
boolean testRow(final int i, final long startTime) throws IOException {
List<RegionInfo> regionInfos = new ArrayList<RegionInfo>();
RegionInfo regionInfo = (RegionInfoBuilder.newBuilder(TableName.valueOf(TABLE_NAME))
.setStartKey(getSplitKey(i))
.setEndKey(getSplitKey(i + 1))
.build());
regionInfos.add(regionInfo);
MetaTableAccessor.addRegionsToMeta(connection, regionInfos, 1);
// write the serverName columns
MetaTableAccessor.updateRegionLocation(connection,
regionInfo, ServerName.valueOf("localhost", 60010, rand.nextLong()), i,
System.currentTimeMillis());
return true;
}
}
static class FilteredScanTest extends TableTest {
protected static final Logger LOG = LoggerFactory.getLogger(FilteredScanTest.class.getName());