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

HBASE-24964 addendum fix TestMetaTableMetrics (#2340) 

Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
Duo Zhang 2020-09-02 10:10:36 +08:00
parent 74807b951b
commit 85a174f5b3
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestMetaTableMetrics.java
View File

@ -19,6 +19,7 @@
package org.apache.hadoop.hbase.coprocessor;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
@ -33,7 +34,6 @@ import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import javax.management.MBeanAttributeInfo;
import javax.management.MBeanInfo;
import javax.management.MBeanServerConnection;
@ -41,7 +41,6 @@ import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HBaseTestingUtility;
@ -141,7 +140,8 @@ public class TestMetaTableMetrics {
public void testMetaTableMetricsInJmx() throws Exception {
UTIL.getAdmin()
.createTable(TableDescriptorBuilder.newBuilder(NAME1).setColumnFamily(CFD).build());
writeData(NAME1);
assertTrue(UTIL.getAdmin().isTableEnabled(NAME1));
readWriteData(NAME1);
UTIL.deleteTable(NAME1);
UTIL.waitFor(30000, 2000, true, () -> {
@ -187,7 +187,7 @@ public class TestMetaTableMetrics {
}
}
private void writeData(TableName tableName) throws IOException {
private void readWriteData(TableName tableName) throws IOException {
try (Table t = UTIL.getConnection().getTable(tableName)) {
List<Put> puts = new ArrayList<>(NUM_ROWS);
for (int i = 0; i < NUM_ROWS; i++) {
@ -196,6 +196,10 @@ public class TestMetaTableMetrics {
puts.add(p);
}
t.put(puts);
for (int i = 0; i < NUM_ROWS; i++) {
Get get = new Get(Bytes.toBytes(i + 1));
assertArrayEquals(Bytes.toBytes(value), t.get(get).getValue(FAMILY, QUALIFIER));
}
}
}