2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements. See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License. You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
18 package org
.apache
.hadoop
.hbase
.wal
;
20 import static org
.junit
.Assert
.assertTrue
;
22 import org
.apache
.hadoop
.fs
.Path
;
23 import org
.apache
.hadoop
.hbase
.HBaseClassTestRule
;
24 import org
.apache
.hadoop
.hbase
.HBaseTestingUtil
;
25 import org
.apache
.hadoop
.hbase
.TableName
;
26 import org
.apache
.hadoop
.hbase
.regionserver
.HRegionServer
;
27 import org
.apache
.hadoop
.hbase
.testclassification
.MediumTests
;
28 import org
.apache
.hadoop
.hbase
.testclassification
.RegionServerTests
;
29 import org
.apache
.hadoop
.hbase
.util
.Bytes
;
30 import org
.junit
.AfterClass
;
31 import org
.junit
.BeforeClass
;
32 import org
.junit
.ClassRule
;
33 import org
.junit
.Test
;
34 import org
.junit
.experimental
.categories
.Category
;
37 * Testcase for HBASE-21843. Used to confirm that we use the correct name for meta wal file when
38 * using {@link RegionGroupingProvider}.
40 @Category({ RegionServerTests
.class, MediumTests
.class })
41 public class TestWrongMetaWALFileName
{
44 public static final HBaseClassTestRule CLASS_RULE
=
45 HBaseClassTestRule
.forClass(TestWrongMetaWALFileName
.class);
47 private static final HBaseTestingUtil UTIL
= new HBaseTestingUtil();
50 public static void setUp() throws Exception
{
51 UTIL
.getConfiguration().set(WALFactory
.WAL_PROVIDER
, WALFactory
.Providers
.multiwal
.name());
52 UTIL
.startMiniCluster(1);
56 public static void tearDown() throws Exception
{
57 UTIL
.shutdownMiniCluster();
61 public void test() throws Exception
{
62 // create a table so that we will write some edits to meta
63 TableName tableName
= TableName
.valueOf("whatever");
64 UTIL
.createTable(tableName
, Bytes
.toBytes("family"));
65 UTIL
.waitTableAvailable(tableName
);
66 HRegionServer rs
= UTIL
.getMiniHBaseCluster().getRegionServer(0);
67 Path walDir
= new Path(rs
.getWALRootDir(),
68 AbstractFSWALProvider
.getWALDirectoryName(rs
.getServerName().toString()));
69 // we should have meta wal files.
71 rs
.getWALFileSystem().listStatus(walDir
, AbstractFSWALProvider
::isMetaFile
).length
> 0);