This is an automated email from the ASF dual-hosted git repository.
liuxiaocs7 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new b6ae493e6f5 HBASE-30244 Use static imports for JUnit 5 Assertions and
Hamcrest Ma… (#8391)
b6ae493e6f5 is described below
commit b6ae493e6f5a0cc733af3ade03a6972d4a2a5c15
Author: Xiao Liu <[email protected]>
AuthorDate: Tue Jun 23 11:28:50 2026 +0800
HBASE-30244 Use static imports for JUnit 5 Assertions and Hamcrest Ma…
(#8391)
Signed-off-by: Duo Zhang <[email protected]>
---
.../TestIncrementalBackupMergeWithFailures.java | 19 ++++++++--------
.../hbase/metrics/TestMetricsExportHelper.java | 10 ++++-----
.../apache/hadoop/hbase/http/TestHttpServer.java | 8 +++----
.../hbase/test/IntegrationTestBigLinkedList.java | 3 ++-
...IntegrationTestBigLinkedListWithVisibility.java | 4 +++-
.../TestVerifyReplicationCrossDiffHdfs.java | 6 +++---
.../hbase/TestIPv6NIOServerSocketChannel.java | 11 ++++++----
.../hadoop/hbase/TestJMXConnectorServer.java | 13 ++++++-----
.../org/apache/hadoop/hbase/TestJMXListener.java | 4 ++--
.../org/apache/hadoop/hbase/TimestampTestBase.java | 25 +++++++++++-----------
.../apache/hadoop/hbase/ipc/TestRpcExecutor.java | 14 ++++++------
.../master/assignment/TestRogueRSAssignment.java | 4 ++--
.../TestVisibilityLabelsReplication.java | 5 ++---
...VisibilityLabelsWithDefaultVisLabelService.java | 3 +--
.../visibility/TestVisibilityWithCheckAuths.java | 6 +++---
.../hadoop/hbase/tool/BulkLoadHFilesTestBase.java | 4 ++--
.../hadoop/hbase/util/TestFSTableDescriptors.java | 3 ++-
.../org/apache/hadoop/hbase/util/TestFSUtils.java | 3 +--
.../apache/hadoop/hbase/util/TestRegionMover1.java | 20 ++++++++---------
.../apache/hadoop/hbase/util/TestRegionMover3.java | 20 +++++++++--------
.../hadoop/hbase/util/TestRegionMoverUseIp.java | 14 ++++++------
21 files changed, 106 insertions(+), 93 deletions(-)
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
index ca066d436c2..e32da7b9c0d 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
@@ -18,8 +18,10 @@
package org.apache.hadoop.hbase.backup;
import static org.apache.hadoop.hbase.backup.util.BackupUtils.succeeded;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
import java.util.ArrayList;
@@ -41,7 +43,6 @@ import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.util.Pair;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
@@ -74,7 +75,7 @@ public class TestIncrementalBackupMergeWithFailures extends
TestBackupBase {
if (val != null) {
failurePhase = FailurePhase.valueOf(val);
} else {
- Assertions.fail("Failure phase is not set");
+ fail("Failure phase is not set");
}
}
@@ -242,13 +243,13 @@ public class TestIncrementalBackupMergeWithFailures
extends TestBackupBase {
Table t1 = insertIntoTable(conn, table1, famName, 1, ADD_ROWS);
LOG.debug("writing " + ADD_ROWS + " rows to " + table1);
- Assertions.assertEquals(NB_ROWS_IN_BATCH + ADD_ROWS,
TEST_UTIL.countRows(t1));
+ assertEquals(NB_ROWS_IN_BATCH + ADD_ROWS, TEST_UTIL.countRows(t1));
t1.close();
LOG.debug("written " + ADD_ROWS + " rows to " + table1);
Table t2 = insertIntoTable(conn, table2, famName, 1, ADD_ROWS);
- Assertions.assertEquals(NB_ROWS_IN_BATCH + ADD_ROWS,
TEST_UTIL.countRows(t2));
+ assertEquals(NB_ROWS_IN_BATCH + ADD_ROWS, TEST_UTIL.countRows(t2));
t2.close();
LOG.debug("written " + ADD_ROWS + " rows to " + table2);
@@ -279,7 +280,7 @@ public class TestIncrementalBackupMergeWithFailures extends
TestBackupBase {
try (BackupAdmin bAdmin = new BackupAdminImpl(conn)) {
String[] backups = new String[] { backupIdIncMultiple,
backupIdIncMultiple2 };
bAdmin.mergeBackups(backups);
- Assertions.fail("Expected IOException");
+ fail("Expected IOException");
} catch (IOException e) {
BackupSystemTable table = new BackupSystemTable(conn);
if (phase.ordinal() < FailurePhase.PHASE4.ordinal()) {
@@ -288,7 +289,7 @@ public class TestIncrementalBackupMergeWithFailures extends
TestBackupBase {
assertFalse(table.isMergeInProgress());
try {
table.finishBackupExclusiveOperation();
- Assertions.fail("IOException is expected");
+ fail("IOException is expected");
} catch (IOException ee) {
// Expected
}
@@ -297,7 +298,7 @@ public class TestIncrementalBackupMergeWithFailures extends
TestBackupBase {
assertTrue(table.isMergeInProgress());
try {
table.startBackupExclusiveOperation();
- Assertions.fail("IOException is expected");
+ fail("IOException is expected");
} catch (IOException ee) {
// Expected - clean up before proceeding
// table.finishMergeOperation();
@@ -330,12 +331,12 @@ public class TestIncrementalBackupMergeWithFailures
extends TestBackupBase {
Table hTable = conn.getTable(table1_restore);
LOG.debug("After incremental restore: " + hTable.getDescriptor());
LOG.debug("f1 has " + TEST_UTIL.countRows(hTable, famName) + " rows");
- Assertions.assertEquals(NB_ROWS_IN_BATCH + 2 * ADD_ROWS,
TEST_UTIL.countRows(hTable, famName));
+ assertEquals(NB_ROWS_IN_BATCH + 2 * ADD_ROWS, TEST_UTIL.countRows(hTable,
famName));
hTable.close();
hTable = conn.getTable(table2_restore);
- Assertions.assertEquals(NB_ROWS_IN_BATCH + 2 * ADD_ROWS,
TEST_UTIL.countRows(hTable));
+ assertEquals(NB_ROWS_IN_BATCH + 2 * ADD_ROWS, TEST_UTIL.countRows(hTable));
hTable.close();
admin.close();
diff --git
a/hbase-hadoop-compat/src/test/java/org/apache/hadoop/hbase/metrics/TestMetricsExportHelper.java
b/hbase-hadoop-compat/src/test/java/org/apache/hadoop/hbase/metrics/TestMetricsExportHelper.java
index ff7436267e5..d71f4f7b40d 100644
---
a/hbase-hadoop-compat/src/test/java/org/apache/hadoop/hbase/metrics/TestMetricsExportHelper.java
+++
b/hbase-hadoop-compat/src/test/java/org/apache/hadoop/hbase/metrics/TestMetricsExportHelper.java
@@ -17,6 +17,8 @@
*/
package org.apache.hadoop.hbase.metrics;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
import java.util.Collection;
import org.apache.hadoop.hbase.testclassification.MetricsTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
@@ -24,7 +26,6 @@ import org.apache.hadoop.metrics2.AbstractMetric;
import org.apache.hadoop.metrics2.MetricsRecord;
import org.apache.hadoop.metrics2.impl.MetricsExportHelper;
import org.apache.hadoop.metrics2.lib.DefaultMetricsSystem;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -49,10 +50,9 @@ public class TestMetricsExportHelper {
Collection<MetricsRecord> metrics = MetricsExportHelper.export();
DefaultMetricsSystem.instance().stop();
- Assertions.assertTrue(metrics.stream().anyMatch(mr ->
mr.name().equals(metricsName)));
- Assertions.assertTrue(contains(metrics, metricsName, gaugeName),
- gaugeName + " is missing in the export");
- Assertions.assertTrue(contains(metrics, metricsName, counterName),
+ assertTrue(metrics.stream().anyMatch(mr -> mr.name().equals(metricsName)));
+ assertTrue(contains(metrics, metricsName, gaugeName), gaugeName + " is
missing in the export");
+ assertTrue(contains(metrics, metricsName, counterName),
counterName + " is missing in the export");
}
diff --git
a/hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestHttpServer.java
b/hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestHttpServer.java
index 1b73f302602..8d5ffb188c1 100644
--- a/hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestHttpServer.java
+++ b/hbase-http/src/test/java/org/apache/hadoop/hbase/http/TestHttpServer.java
@@ -17,6 +17,7 @@
*/
package org.apache.hadoop.hbase.http;
+import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.greaterThan;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
@@ -73,7 +74,6 @@ import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
-import org.hamcrest.MatcherAssert;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Disabled;
@@ -297,7 +297,7 @@ public class TestHttpServer extends
HttpServerFunctionalTest {
assertNotNull(entity);
assertNull(entity.getContentEncoding());
unencodedContentLength = entity.getContentLength();
- MatcherAssert.assertThat(unencodedContentLength, greaterThan(0L));
+ assertThat(unencodedContentLength, greaterThan(0L));
final String unencodedEntityBody = readFully(entity.getContent());
assertEquals(sourceContent, unencodedEntityBody);
}
@@ -310,13 +310,13 @@ public class TestHttpServer extends
HttpServerFunctionalTest {
assertNotNull(entity.getContentEncoding());
assertEquals("gzip", entity.getContentEncoding().getValue());
encodedContentLength = entity.getContentLength();
- MatcherAssert.assertThat(encodedContentLength, greaterThan(0L));
+ assertThat(encodedContentLength, greaterThan(0L));
final String encodedEntityBody = readFully(entity.getContent());
// the encoding/decoding process, as implemented in this specific
combination of dependency
// versions, does not perfectly preserve trailing whitespace. thus,
`trim()`.
assertEquals(sourceContent.trim(), encodedEntityBody.trim());
}
- MatcherAssert.assertThat(unencodedContentLength,
greaterThan(encodedContentLength));
+ assertThat(unencodedContentLength, greaterThan(encodedContentLength));
}
}
diff --git
a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
index 0b1da0568ff..a19ebc0b3f1 100644
---
a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
+++
b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
@@ -21,6 +21,7 @@ import static
org.apache.hadoop.hbase.IntegrationTestingUtility.DEFAULT_REGIONS_
import static
org.apache.hadoop.hbase.IntegrationTestingUtility.PRESPLIT_TEST_TABLE;
import static
org.apache.hadoop.hbase.IntegrationTestingUtility.PRESPLIT_TEST_TABLE_KEY;
import static
org.apache.hadoop.hbase.IntegrationTestingUtility.REGIONS_PER_SERVER_KEY;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import java.io.DataInput;
import java.io.DataOutput;
@@ -1872,7 +1873,7 @@ public class IntegrationTestBigLinkedList extends
IntegrationTestBase {
}
int ret = ToolRunner.run(conf, new Loop(), new String[] { "1", "1",
"2000000",
util.getDataTestDirOnTestFS("IntegrationTestBigLinkedList").toString(),
"1" });
- org.junit.jupiter.api.Assertions.assertEquals(0, ret);
+ assertEquals(0, ret);
}
private void usage() {
diff --git
a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedListWithVisibility.java
b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedListWithVisibility.java
index bc9d7af3446..8f3dcbf03ff 100644
---
a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedListWithVisibility.java
+++
b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedListWithVisibility.java
@@ -17,6 +17,8 @@
*/
package org.apache.hadoop.hbase.test;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
import java.io.IOException;
import java.security.PrivilegedExceptionAction;
import java.util.Arrays;
@@ -635,7 +637,7 @@ public class IntegrationTestBigLinkedListWithVisibility
extends IntegrationTestB
new String[] { "1", "1", "20000",
util.getDataTestDirOnTestFS("IntegrationTestBigLinkedListWithVisibility").toString(),
"1",
"10000" });
- org.junit.jupiter.api.Assertions.assertEquals(0, ret);
+ assertEquals(0, ret);
}
public static void main(String[] args) throws Exception {
diff --git
a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyReplicationCrossDiffHdfs.java
b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyReplicationCrossDiffHdfs.java
index b1ee7768155..09f4d03c39b 100644
---
a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyReplicationCrossDiffHdfs.java
+++
b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyReplicationCrossDiffHdfs.java
@@ -18,6 +18,7 @@
package org.apache.hadoop.hbase.replication;
import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
@@ -47,7 +48,6 @@ import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
import org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster;
import org.apache.hadoop.mapreduce.Job;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -140,8 +140,8 @@ public class TestVerifyReplicationCrossDiffHdfs {
}
}
}
- Assertions.assertNotNull(results);
- Assertions.assertEquals(10, results.length);
+ assertNotNull(results);
+ assertEquals(10, results.length);
}
@AfterAll
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIPv6NIOServerSocketChannel.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIPv6NIOServerSocketChannel.java
index a6278eabbca..13af8690948 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIPv6NIOServerSocketChannel.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIPv6NIOServerSocketChannel.java
@@ -17,6 +17,10 @@
*/
package org.apache.hadoop.hbase;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
import java.io.IOException;
import java.net.BindException;
import java.net.InetAddress;
@@ -26,7 +30,6 @@ import java.nio.channels.ServerSocketChannel;
import java.util.Locale;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
@@ -116,8 +119,8 @@ public class TestIPv6NIOServerSocketChannel {
// On Windows JDK6, we will get expected exception:
// java.net.SocketException: Address family not supported by protocol
family
// or java.net.SocketException: Protocol family not supported
- Assertions.assertFalse(ex instanceof BindException);
-
Assertions.assertTrue(ex.getMessage().toLowerCase(Locale.ROOT).contains("protocol
family"));
+ assertFalse(ex instanceof BindException);
+ assertTrue(ex.getMessage().toLowerCase(Locale.ROOT).contains("protocol
family"));
LOG.info("Received expected exception:", ex);
// if this is the case, ensure that we are running on preferIPv4=true
@@ -132,7 +135,7 @@ public class TestIPv6NIOServerSocketChannel {
InetAddress[] addrs = InetAddress.getAllByName("localhost");
for (InetAddress addr : addrs) {
LOG.info("resolved localhost as:" + addr);
- Assertions.assertEquals(4, addr.getAddress().length); // ensure 4 byte
ipv4 address
+ assertEquals(4, addr.getAddress().length); // ensure 4 byte ipv4 address
}
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXConnectorServer.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXConnectorServer.java
index 68fbd798068..7e85c3137bc 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXConnectorServer.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXConnectorServer.java
@@ -17,6 +17,10 @@
*/
package org.apache.hadoop.hbase;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+
import java.io.IOException;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
@@ -33,7 +37,6 @@ import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Tag;
@@ -101,7 +104,7 @@ public class TestJMXConnectorServer {
LOG.info("Exception occurred while stopping HMaster. ", e);
accessDenied = true;
}
- Assertions.assertTrue(accessDenied);
+ assertTrue(accessDenied);
checkConnector();
}
@@ -132,7 +135,7 @@ public class TestJMXConnectorServer {
LOG.error("Exception occurred while stopping HMaster. ", e);
accessDenied = true;
}
- Assertions.assertTrue(accessDenied);
+ assertTrue(accessDenied);
checkConnector();
}
@@ -145,10 +148,10 @@ public class TestJMXConnectorServer {
.connect(JMXListener.buildJMXServiceURL(rmiRegistryPort,
rmiRegistryPort));
} catch (IOException e) {
if (e.getCause() instanceof ServiceUnavailableException) {
- Assertions.fail("Can't connect to ConnectorServer.");
+ fail("Can't connect to ConnectorServer.");
}
}
- Assertions.assertNotNull(connector, "JMXConnector should not be null.");
+ assertNotNull(connector, "JMXConnector should not be null.");
connector.close();
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXListener.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXListener.java
index d8bab2037d8..b6c7c2a3f2c 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXListener.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestJMXListener.java
@@ -18,6 +18,7 @@
package org.apache.hadoop.hbase;
import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
@@ -31,7 +32,6 @@ import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.apache.hadoop.hbase.util.JVMClusterUtil;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -96,7 +96,7 @@ public class TestJMXListener {
MBeanServerConnection mb = connector.getMBeanServerConnection();
String domain = mb.getDefaultDomain();
- Assertions.assertTrue(!domain.isEmpty(), "default domain is not correct");
+ assertTrue(!domain.isEmpty(), "default domain is not correct");
connector.close();
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/TimestampTestBase.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/TimestampTestBase.java
index 5f13ec274e1..f69223ef62e 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TimestampTestBase.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TimestampTestBase.java
@@ -17,6 +17,8 @@
*/
package org.apache.hadoop.hbase;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
import java.io.IOException;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Durability;
@@ -27,7 +29,6 @@ import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
-import org.junit.jupiter.api.Assertions;
/**
* Tests user specifiable time stamps putting, getting and scanning. Also
tests same in presence of
@@ -104,9 +105,9 @@ public class TimestampTestBase {
get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
get.readVersions(3);
Result result = incommon.get(get);
- Assertions.assertEquals(1, result.size());
+ assertEquals(1, result.size());
long time = Bytes.toLong(CellUtil.cloneValue(result.rawCells()[0]));
- Assertions.assertEquals(time, currentTime);
+ assertEquals(time, currentTime);
}
/*
@@ -122,7 +123,7 @@ public class TimestampTestBase {
Result r = incommon.get(get);
byte[] bytes = r.getValue(FAMILY_NAME, QUALIFIER_NAME);
long t = Bytes.toLong(bytes);
- Assertions.assertEquals(tss[0], t);
+ assertEquals(tss[0], t);
// Now assert that if we ask for multiple versions, that they come out in
// order.
@@ -131,10 +132,10 @@ public class TimestampTestBase {
get.readVersions(tss.length);
Result result = incommon.get(get);
Cell[] kvs = result.rawCells();
- Assertions.assertEquals(kvs.length, tss.length);
+ assertEquals(kvs.length, tss.length);
for (int i = 0; i < kvs.length; i++) {
t = Bytes.toLong(CellUtil.cloneValue(kvs[i]));
- Assertions.assertEquals(tss[i], t);
+ assertEquals(tss[i], t);
}
// Determine highest stamp to set as next max stamp
@@ -147,10 +148,10 @@ public class TimestampTestBase {
get.readVersions(kvs.length - 1);
result = incommon.get(get);
kvs = result.rawCells();
- Assertions.assertEquals(kvs.length, tss.length - 1);
+ assertEquals(kvs.length, tss.length - 1);
for (int i = 1; i < kvs.length; i++) {
t = Bytes.toLong(CellUtil.cloneValue(kvs[i - 1]));
- Assertions.assertEquals(tss[i], t);
+ assertEquals(tss[i], t);
}
// Test scanner returns expected version
@@ -169,12 +170,12 @@ public class TimestampTestBase {
// Get count of latest items.
int count = assertScanContentTimestamp(incommon,
HConstants.LATEST_TIMESTAMP);
// Assert I get same count when I scan at each timestamp.
- Assertions.assertEquals(count, assertScanContentTimestamp(incommon, T0));
- Assertions.assertEquals(count, assertScanContentTimestamp(incommon, T1));
+ assertEquals(count, assertScanContentTimestamp(incommon, T0));
+ assertEquals(count, assertScanContentTimestamp(incommon, T1));
// Flush everything out to disk and then retry
flusher.flushcache();
- Assertions.assertEquals(count, assertScanContentTimestamp(incommon, T0));
- Assertions.assertEquals(count, assertScanContentTimestamp(incommon, T1));
+ assertEquals(count, assertScanContentTimestamp(incommon, T0));
+ assertEquals(count, assertScanContentTimestamp(incommon, T1));
}
/*
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestRpcExecutor.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestRpcExecutor.java
index 533aa7bd663..2d6a092b590 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestRpcExecutor.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestRpcExecutor.java
@@ -21,6 +21,7 @@ import static
org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_HANDLER_FACTOR_
import static
org.apache.hadoop.hbase.ipc.RpcExecutor.DEFAULT_CALL_QUEUE_HANDLER_FACTOR;
import static
org.apache.hadoop.hbase.ipc.RpcExecutor.DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT;
import static
org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.mockito.Mockito.mock;
import java.util.List;
@@ -29,7 +30,6 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RPCTests;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -63,19 +63,19 @@ public class TestRpcExecutor {
List<BlockingQueue<CallRunner>> queues = executor.getQueues();
int expectedQueueSize = Math.round(handlerCount *
DEFAULT_CALL_QUEUE_HANDLER_FACTOR);
- Assertions.assertEquals(expectedQueueSize, queues.size(),
+ assertEquals(expectedQueueSize, queues.size(),
"Number of queues should be according to default
callQueueHandlerFactor");
// By default, the soft limit depends on number of handler the queue will
serve
int expectedSoftLimit =
(handlerCount / expectedQueueSize) *
DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER;
- Assertions.assertEquals(expectedSoftLimit, executor.currentQueueLimit,
+ assertEquals(expectedSoftLimit, executor.currentQueueLimit,
"Soft limit of queues is wrongly calculated");
// Hard limit should be maximum of softLimit and
DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT
int hardQueueLimit = queues.get(0).remainingCapacity() +
queues.get(0).size();
int expectedHardLimit = Math.max(expectedSoftLimit,
DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT);
- Assertions.assertEquals(expectedHardLimit, hardQueueLimit,
+ assertEquals(expectedHardLimit, hardQueueLimit,
"Default hard limit of queues is wrongly calculated ");
}
@@ -94,17 +94,17 @@ public class TestRpcExecutor {
new BalancedQueueRpcExecutor(testInfo.getTestMethod().get().getName() +
"1", handlerCount,
maxQueueLength, qosFunction, conf, null);
- Assertions.assertEquals(maxQueueLength, executor.currentQueueLimit,
+ assertEquals(maxQueueLength, executor.currentQueueLimit,
"Configured soft limit is not applied.");
List<BlockingQueue<CallRunner>> queues1 = executor.getQueues();
int expectedQueueSize = Math.round(handlerCount * callQueueHandlerFactor);
- Assertions.assertEquals(expectedQueueSize, queues1.size(),
+ assertEquals(expectedQueueSize, queues1.size(),
"Number of queues should be according to callQueueHandlerFactor");
int hardQueueLimit1 = queues1.get(0).remainingCapacity() +
queues1.get(0).size();
- Assertions.assertEquals(DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT,
hardQueueLimit1,
+ assertEquals(DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT, hardQueueLimit1,
"Default Hard limit is not applied");
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRogueRSAssignment.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRogueRSAssignment.java
index df27d11a2bc..ab00ed0aad6 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRogueRSAssignment.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRogueRSAssignment.java
@@ -17,6 +17,7 @@
*/
package org.apache.hadoop.hbase.master.assignment;
+import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.core.Is.isA;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -155,8 +156,7 @@ public class TestRogueRSAssignment {
// TODO: replace YouAreDeadException with appropriate exception as and
when necessary
ServiceException exception = assertThrows(ServiceException.class,
() -> master.getMasterRpcServices().regionServerReport(null,
request.build()));
- org.hamcrest.MatcherAssert.assertThat((YouAreDeadException)
exception.getCause(),
- isA(YouAreDeadException.class));
+ assertThat((YouAreDeadException) exception.getCause(),
isA(YouAreDeadException.class));
}
private RegionServerStatusProtos.RegionServerReportRequest.Builder
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsReplication.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsReplication.java
index 644e7d23171..119b85acd05 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsReplication.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsReplication.java
@@ -70,7 +70,6 @@ import org.apache.hadoop.hbase.wal.WAL.Entry;
import org.apache.hadoop.hbase.wal.WALEdit;
import org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster;
import org.apache.hadoop.hbase.zookeeper.ZKWatcher;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
@@ -276,9 +275,9 @@ public class TestVisibilityLabelsReplication {
if (VisibilityReplicationEndPointForTest.lastEntries == null) {
return; // first call
}
- Assertions.assertEquals(1,
VisibilityReplicationEndPointForTest.lastEntries.size());
+ assertEquals(1, VisibilityReplicationEndPointForTest.lastEntries.size());
List<Cell> cells =
VisibilityReplicationEndPointForTest.lastEntries.get(0).getEdit().getCells();
- Assertions.assertEquals(4, cells.size());
+ assertEquals(4, cells.size());
boolean tagFound = false;
for (Cell cell : cells) {
if (
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsWithDefaultVisLabelService.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsWithDefaultVisLabelService.java
index b67f51fcaff..e9477ce94dd 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsWithDefaultVisLabelService.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityLabelsWithDefaultVisLabelService.java
@@ -42,7 +42,6 @@ import
org.apache.hadoop.hbase.testclassification.SecurityTests;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread;
import org.apache.hadoop.hbase.util.Threads;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -176,7 +175,7 @@ public class TestVisibilityLabelsWithDefaultVisLabelService
extends VisibilityLa
}
}
// One label is the "system" label.
- Assertions.assertEquals(13, i, "The count should be 13");
+ assertEquals(13, i, "The count should be 13");
}
@Test
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityWithCheckAuths.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityWithCheckAuths.java
index 3867d847055..d96a79c58c5 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityWithCheckAuths.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/visibility/TestVisibilityWithCheckAuths.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.security.visibility;
import static
org.apache.hadoop.hbase.security.visibility.VisibilityConstants.LABELS_TABLE_NAME;
import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
import java.security.PrivilegedExceptionAction;
@@ -40,7 +41,6 @@ import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.SecurityTests;
import org.apache.hadoop.hbase.util.Bytes;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
@@ -137,7 +137,7 @@ public class TestVisibilityWithCheckAuths {
p.setCellVisibility(new CellVisibility(PUBLIC + "&" + TOPSECRET));
p.addColumn(fam, qual, 125L, value);
table.put(p);
- Assertions.fail("Testcase should fail with AccesDeniedException");
+ fail("Testcase should fail with AccessDeniedException");
} catch (Throwable t) {
assertTrue(t.getMessage().contains("AccessDeniedException"));
}
@@ -204,7 +204,7 @@ public class TestVisibilityWithCheckAuths {
append.addColumn(fam, qual, Bytes.toBytes("c"));
append.setCellVisibility(new CellVisibility(PUBLIC));
table.append(append);
- Assertions.fail("Testcase should fail with AccesDeniedException");
+ fail("Testcase should fail with AccessDeniedException");
} catch (Throwable t) {
assertTrue(t.getMessage().contains("AccessDeniedException"));
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTestBase.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTestBase.java
index 91ad1585304..99b9a72c2d6 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTestBase.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTestBase.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.tool;
import static org.apache.hadoop.hbase.HBaseTestingUtil.countRows;
import static
org.apache.hadoop.hbase.util.LocatedBlockHelper.getLocatedBlockLocations;
+import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.greaterThan;
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -68,7 +69,6 @@ import org.apache.hadoop.hdfs.DistributedFileSystem;
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
import org.apache.hadoop.hdfs.protocol.LocatedBlock;
import org.apache.hadoop.hdfs.protocol.LocatedBlocks;
-import org.hamcrest.MatcherAssert;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;
@@ -664,7 +664,7 @@ public class BulkLoadHFilesTestBase {
try (HFile.Reader reader =
HFile.createReader(p.getFileSystem(conf), p, new CacheConfig(conf),
true, conf)) {
long fileCreateTime =
reader.getHFileInfo().getHFileContext().getFileCreateTime();
- MatcherAssert.assertThat(fileCreateTime, greaterThan(0L));
+ assertThat(fileCreateTime, greaterThan(0L));
}
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSTableDescriptors.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSTableDescriptors.java
index ca722b18ba2..4c98a345dc9 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSTableDescriptors.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSTableDescriptors.java
@@ -22,6 +22,7 @@ import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;
@@ -81,7 +82,7 @@ public class TestFSTableDescriptors {
assertEquals(0, i);
// Assert it won't eat garbage -- that it fails
Path p2 = new Path(testDir, "abc");
-
org.junit.jupiter.api.Assertions.assertThrows(IllegalArgumentException.class,
+ assertThrows(IllegalArgumentException.class,
() -> FSTableDescriptors.getTableInfoSequenceIdAndFileLength(p2));
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java
index 80f8ec57d31..c94f0100015 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java
@@ -432,8 +432,7 @@ public class TestFSUtils {
CommonFSUtils.setStoragePolicy(testFs, new Path("non-exist"),
HConstants.DEFAULT_WAL_STORAGE_POLICY, true);
} catch (IOException e) {
- org.junit.jupiter.api.Assertions
- .fail("Should have bypassed the FS API when setting default storage
policy");
+ fail("Should have bypassed the FS API when setting default storage
policy");
}
// There should be exception thrown when given non-default storage policy,
which indicates the
// HDFS API has been called
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
index 0613a84ff09..646cd5ea2d8 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.util;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import java.io.File;
import java.io.FileWriter;
@@ -43,7 +44,6 @@ import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.apache.hadoop.hbase.util.RegionMover.RegionMoverBuilder;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Tag;
@@ -345,7 +345,7 @@ public class TestRegionMover1 {
int sourceServerRegions = regionServer.getRegions().size();
try (RegionMover regionMover = rmBuilder.build()) {
- Assertions.assertTrue(regionMover.unload());
+ assertTrue(regionMover.unload());
LOG.info("Unloading {}", hostname);
assertEquals(0, regionServer.getNumberOfOnlineRegions());
assertEquals(regionsExcludeServer,
cluster.getRegionServer(1).getNumberOfOnlineRegions());
@@ -354,11 +354,11 @@ public class TestRegionMover1 {
List<HRegion> regionList = cluster.getRegionServer(1).getRegions();
int index = 0;
for (HRegion hRegion : regionList) {
- Assertions.assertEquals(hRegion, regions.get(index++));
+ assertEquals(hRegion, regions.get(index++));
}
- Assertions.assertEquals(targetServerRegions + sourceServerRegions,
+ assertEquals(targetServerRegions + sourceServerRegions,
cluster.getRegionServer(2).getNumberOfOnlineRegions());
- Assertions.assertTrue(regionMover.load());
+ assertTrue(regionMover.load());
}
TEST_UTIL.getAdmin().recommissionRegionServer(excludeServer.getServerName(),
@@ -400,7 +400,7 @@ public class TestRegionMover1 {
int sourceServerRegions = sourceRegionServer.getRegions().size();
try (RegionMover regionMover = rmBuilder.build()) {
- Assertions.assertTrue(regionMover.unload());
+ assertTrue(regionMover.unload());
LOG.info("Unloading {}", hostname);
assertEquals(0, sourceRegionServer.getNumberOfOnlineRegions());
assertEquals(regionsExcludeServer,
cluster.getRegionServer(0).getNumberOfOnlineRegions());
@@ -409,11 +409,11 @@ public class TestRegionMover1 {
List<HRegion> regionList = cluster.getRegionServer(0).getRegions();
int index = 0;
for (HRegion hRegion : regionList) {
- Assertions.assertEquals(hRegion, regions.get(index++));
+ assertEquals(hRegion, regions.get(index++));
}
- Assertions.assertEquals(targetServerRegions + sourceServerRegions,
+ assertEquals(targetServerRegions + sourceServerRegions,
cluster.getRegionServer(2).getNumberOfOnlineRegions());
- Assertions.assertTrue(regionMover.load());
+ assertTrue(regionMover.load());
}
TEST_UTIL.getAdmin().recommissionRegionServer(excludeServer.getServerName(),
@@ -446,7 +446,7 @@ public class TestRegionMover1 {
new RegionMoverBuilder(sourceServer,
TEST_UTIL.getConfiguration()).ack(true)
.excludeFile(excludeFile.getCanonicalPath());
try (RegionMover regionMover = rmBuilder.build()) {
- Assertions.assertFalse(regionMover.unload());
+ assertFalse(regionMover.unload());
}
TEST_UTIL.getAdmin().recommissionRegionServer(decomServer.getServerName(),
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover3.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover3.java
index afbfeb7fcba..0afa890e303 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover3.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover3.java
@@ -17,6 +17,9 @@
*/
package org.apache.hadoop.hbase.util;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
@@ -37,7 +40,6 @@ import org.apache.hadoop.hbase.regionserver.HRegionServer;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Tag;
@@ -98,9 +100,9 @@ public class TestRegionMover3 {
int numRegions1 = hRegionServer1.getNumberOfOnlineRegions();
int numRegions2 = hRegionServer2.getNumberOfOnlineRegions();
- Assertions.assertTrue(numRegions0 >= 3);
- Assertions.assertTrue(numRegions1 >= 3);
- Assertions.assertTrue(numRegions2 >= 3);
+ assertTrue(numRegions0 >= 3);
+ assertTrue(numRegions1 >= 3);
+ assertTrue(numRegions2 >= 3);
int totalRegions = numRegions0 + numRegions1 + numRegions2;
// source RS: rs0
@@ -127,8 +129,8 @@ public class TestRegionMover3 {
int newNumRegions0 = hRegionServer0.getNumberOfOnlineRegions();
int newNumRegions1 = hRegionServer1.getNumberOfOnlineRegions();
int newNumRegions2 = hRegionServer2.getNumberOfOnlineRegions();
- Assertions.assertEquals(0, newNumRegions1);
- Assertions.assertEquals(totalRegions, newNumRegions0 + newNumRegions2);
+ assertEquals(0, newNumRegions1);
+ assertEquals(totalRegions, newNumRegions0 + newNumRegions2);
}
// use custom rackManager, which resolves "rack-1" for rs0 and rs1,
@@ -141,9 +143,9 @@ public class TestRegionMover3 {
int newNumRegions0 = hRegionServer0.getNumberOfOnlineRegions();
int newNumRegions1 = hRegionServer1.getNumberOfOnlineRegions();
int newNumRegions2 = hRegionServer2.getNumberOfOnlineRegions();
- Assertions.assertEquals(0, newNumRegions0);
- Assertions.assertEquals(0, newNumRegions1);
- Assertions.assertEquals(totalRegions, newNumRegions2);
+ assertEquals(0, newNumRegions0);
+ assertEquals(0, newNumRegions1);
+ assertEquals(totalRegions, newNumRegions2);
}
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMoverUseIp.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMoverUseIp.java
index 889eac45262..cf972dd0989 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMoverUseIp.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMoverUseIp.java
@@ -17,6 +17,9 @@
*/
package org.apache.hadoop.hbase.util;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
@@ -37,7 +40,6 @@ import org.apache.hadoop.hbase.regionserver.HRegionServer;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Tag;
@@ -112,9 +114,9 @@ public class TestRegionMoverUseIp {
int numRegions1 = hRegionServer1.getNumberOfOnlineRegions();
int numRegions2 = hRegionServer2.getNumberOfOnlineRegions();
- Assertions.assertTrue(numRegions0 >= 3);
- Assertions.assertTrue(numRegions1 >= 3);
- Assertions.assertTrue(numRegions2 >= 3);
+ assertTrue(numRegions0 >= 3);
+ assertTrue(numRegions1 >= 3);
+ assertTrue(numRegions2 >= 3);
int totalRegions = numRegions0 + numRegions1 + numRegions2;
// source RS: rs0
@@ -127,8 +129,8 @@ public class TestRegionMoverUseIp {
int newNumRegions0 = hRegionServer0.getNumberOfOnlineRegions();
int newNumRegions1 = hRegionServer1.getNumberOfOnlineRegions();
int newNumRegions2 = hRegionServer2.getNumberOfOnlineRegions();
- Assertions.assertEquals(0, newNumRegions0);
- Assertions.assertEquals(totalRegions, newNumRegions1 + newNumRegions2);
+ assertEquals(0, newNumRegions0);
+ assertEquals(totalRegions, newNumRegions1 + newNumRegions2);
}
}
}
