HBASE-20193 Move TestCreateTableProcedure.testMRegions to a separated file
This commit is contained in:
parent
87f9b4accd
commit
b318311dfd
@ -22,7 +22,6 @@ import static org.junit.Assert.assertTrue;
|
|||||||
import static org.junit.Assert.fail;
|
import static org.junit.Assert.fail;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
import org.apache.hadoop.conf.Configuration;
|
import org.apache.hadoop.conf.Configuration;
|
||||||
import org.apache.hadoop.fs.FileSystem;
|
import org.apache.hadoop.fs.FileSystem;
|
||||||
import org.apache.hadoop.fs.Path;
|
import org.apache.hadoop.fs.Path;
|
||||||
@ -49,25 +48,21 @@ import org.junit.Rule;
|
|||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.experimental.categories.Category;
|
import org.junit.experimental.categories.Category;
|
||||||
import org.junit.rules.TestName;
|
import org.junit.rules.TestName;
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos;
|
import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos;
|
||||||
|
|
||||||
|
|
||||||
@Category({MasterTests.class, MediumTests.class})
|
@Category({MasterTests.class, MediumTests.class})
|
||||||
public class TestCreateTableProcedure extends TestTableDDLProcedureBase {
|
public class TestCreateTableProcedure extends TestTableDDLProcedureBase {
|
||||||
|
|
||||||
@ClassRule
|
@ClassRule
|
||||||
public static final HBaseClassTestRule CLASS_RULE =
|
public static final HBaseClassTestRule CLASS_RULE =
|
||||||
HBaseClassTestRule.forClass(TestCreateTableProcedure.class);
|
HBaseClassTestRule.forClass(TestCreateTableProcedure.class);
|
||||||
|
|
||||||
private static final Logger LOG = LoggerFactory.getLogger(TestCreateTableProcedure.class);
|
|
||||||
|
|
||||||
private static final String F1 = "f1";
|
private static final String F1 = "f1";
|
||||||
private static final String F2 = "f2";
|
private static final String F2 = "f2";
|
||||||
|
|
||||||
@Rule public TestName name = new TestName();
|
@Rule
|
||||||
|
public TestName name = new TestName();
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testSimpleCreate() throws Exception {
|
public void testSimpleCreate() throws Exception {
|
||||||
@ -202,20 +197,6 @@ public class TestCreateTableProcedure extends TestTableDDLProcedureBase {
|
|||||||
testSimpleCreate(tableName, splitKeys);
|
testSimpleCreate(tableName, splitKeys);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
|
||||||
public void testMRegions() throws Exception {
|
|
||||||
final byte[][] splitKeys = new byte[500][];
|
|
||||||
for (int i = 0; i < splitKeys.length; ++i) {
|
|
||||||
splitKeys[i] = Bytes.toBytes(String.format("%08d", i));
|
|
||||||
}
|
|
||||||
|
|
||||||
final TableDescriptor htd = MasterProcedureTestingUtility.createHTD(
|
|
||||||
TableName.valueOf("TestMRegions"), F1, F2);
|
|
||||||
UTIL.getAdmin().createTableAsync(htd, splitKeys)
|
|
||||||
.get(10, java.util.concurrent.TimeUnit.HOURS);
|
|
||||||
LOG.info("TABLE CREATED");
|
|
||||||
}
|
|
||||||
|
|
||||||
public static class CreateTableProcedureOnHDFSFailure extends CreateTableProcedure {
|
public static class CreateTableProcedureOnHDFSFailure extends CreateTableProcedure {
|
||||||
private boolean failOnce = false;
|
private boolean failOnce = false;
|
||||||
|
|
||||||
|
@ -0,0 +1,66 @@
|
|||||||
|
/**
|
||||||
|
* Licensed to the Apache Software Foundation (ASF) under one
|
||||||
|
* or more contributor license agreements. See the NOTICE file
|
||||||
|
* distributed with this work for additional information
|
||||||
|
* regarding copyright ownership. The ASF licenses this file
|
||||||
|
* to you under the Apache License, Version 2.0 (the
|
||||||
|
* "License"); you may not use this file except in compliance
|
||||||
|
* with the License. You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
package org.apache.hadoop.hbase.master.procedure;
|
||||||
|
|
||||||
|
import org.apache.hadoop.hbase.HBaseClassTestRule;
|
||||||
|
import org.apache.hadoop.hbase.HBaseTestingUtility;
|
||||||
|
import org.apache.hadoop.hbase.TableName;
|
||||||
|
import org.apache.hadoop.hbase.client.TableDescriptor;
|
||||||
|
import org.apache.hadoop.hbase.testclassification.LargeTests;
|
||||||
|
import org.apache.hadoop.hbase.testclassification.MasterTests;
|
||||||
|
import org.apache.hadoop.hbase.util.Bytes;
|
||||||
|
import org.junit.AfterClass;
|
||||||
|
import org.junit.BeforeClass;
|
||||||
|
import org.junit.ClassRule;
|
||||||
|
import org.junit.Test;
|
||||||
|
import org.junit.experimental.categories.Category;
|
||||||
|
|
||||||
|
@Category({ MasterTests.class, LargeTests.class })
|
||||||
|
public class TestCreateTableProcedureMuitipleRegions {
|
||||||
|
|
||||||
|
@ClassRule
|
||||||
|
public static final HBaseClassTestRule CLASS_RULE =
|
||||||
|
HBaseClassTestRule.forClass(TestCreateTableProcedureMuitipleRegions.class);
|
||||||
|
|
||||||
|
private static final HBaseTestingUtility UTIL = new HBaseTestingUtility();
|
||||||
|
|
||||||
|
private static final String F1 = "f1";
|
||||||
|
private static final String F2 = "f2";
|
||||||
|
|
||||||
|
@BeforeClass
|
||||||
|
public static void setUp() throws Exception {
|
||||||
|
UTIL.startMiniCluster(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
@AfterClass
|
||||||
|
public static void tearDown() throws Exception {
|
||||||
|
UTIL.shutdownMiniCluster();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testMRegions() throws Exception {
|
||||||
|
byte[][] splitKeys = new byte[500][];
|
||||||
|
for (int i = 0; i < splitKeys.length; ++i) {
|
||||||
|
splitKeys[i] = Bytes.toBytes(String.format("%08d", i));
|
||||||
|
}
|
||||||
|
|
||||||
|
TableDescriptor htd =
|
||||||
|
MasterProcedureTestingUtility.createHTD(TableName.valueOf("TestMRegions"), F1, F2);
|
||||||
|
UTIL.getAdmin().createTableAsync(htd, splitKeys).get(10, java.util.concurrent.TimeUnit.HOURS);
|
||||||
|
}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user