From e1b3e4e783c17c7ee53daee8e0ef3660351efe91 Mon Sep 17 00:00:00 2001 From: Umesh Agashe Date: Thu, 24 Aug 2017 11:10:17 -0700 Subject: [PATCH] HBASE-18674 upgrading to commons-lang3 --- dev-support/docker/Dockerfile | 2 +- hbase-backup/pom.xml | 4 +-- .../org/apache/hadoop/hbase/backup/BackupInfo.java | 2 +- .../apache/hadoop/hbase/backup/RestoreDriver.java | 2 +- .../hadoop/hbase/backup/impl/BackupAdminImpl.java | 2 +- .../hadoop/hbase/backup/impl/BackupCommands.java | 2 +- .../hbase/backup/impl/BackupSystemTable.java | 2 +- .../backup/impl/IncrementalTableBackupClient.java | 2 +- .../hbase/backup/impl/RestoreTablesClient.java | 2 +- .../backup/mapreduce/MapReduceBackupMergeJob.java | 2 +- .../backup/mapreduce/MapReduceRestoreJob.java | 2 +- .../apache/hadoop/hbase/backup/util/BackupSet.java | 2 +- .../hadoop/hbase/backup/TestFullRestore.java | 4 +-- .../TestIncrementalBackupMergeWithFailures.java | 2 +- hbase-client/pom.xml | 4 +-- .../apache/hadoop/hbase/client/ClientScanner.java | 2 +- .../hbase/client/FastFailInterceptorContext.java | 4 +-- .../client/PreemptiveFastFailInterceptor.java | 2 +- .../hadoop/hbase/client/ZKAsyncRegistry.java | 4 +-- .../client/replication/ReplicationSerDeHelper.java | 2 +- .../hadoop/hbase/client/replication/TableCFs.java | 2 +- .../hbase/ipc/NettyRpcClientConfigHelper.java | 2 +- .../hadoop/hbase/quotas/SpaceQuotaSnapshot.java | 2 +- .../org/apache/hadoop/hbase/zookeeper/ZKUtil.java | 2 +- .../hadoop/hbase/client/TestClientNoCluster.java | 14 ++++----- .../hadoop/hbase/ipc/TestCellBlockBuilder.java | 2 +- hbase-common/pom.xml | 4 +-- .../java/org/apache/hadoop/hbase/HConstants.java | 4 ++- .../hadoop/hbase/io/encoding/EncodedDataBlock.java | 2 +- .../apache/hadoop/hbase/util/PairOfSameType.java | 5 ++-- hbase-hadoop2-compat/pom.xml | 4 +-- .../impl/HBaseMetrics2HadoopMetricsAdapter.java | 2 +- .../hadoop/metrics2/lib/MutableHistogram.java | 2 +- hbase-it/pom.xml | 4 +-- .../hadoop/hbase/DistributedHBaseCluster.java | 4 +-- .../apache/hadoop/hbase/HBaseClusterManager.java | 2 +- .../apache/hadoop/hbase/IntegrationTestBase.java | 2 +- .../hbase/IntegrationTestDDLMasterFailover.java | 32 ++++++++++----------- .../hadoop/hbase/IntegrationTestIngestWithACL.java | 2 +- .../StripeCompactionsPerformanceEvaluation.java | 2 +- .../apache/hadoop/hbase/chaos/actions/Action.java | 6 ++-- .../hbase/chaos/actions/AddColumnAction.java | 2 +- .../hbase/chaos/actions/CompactMobAction.java | 4 +-- .../actions/CompactRandomRegionOfTableAction.java | 4 +-- .../hbase/chaos/actions/CompactTableAction.java | 4 +-- .../MergeRandomAdjacentRegionsOfTableAction.java | 4 +-- .../chaos/actions/MoveRegionsOfTableAction.java | 4 +-- .../chaos/actions/RestartRsHoldingTableAction.java | 4 +-- .../chaos/actions/RollingBatchRestartRsAction.java | 6 ++-- .../actions/UnbalanceKillAndRebalanceAction.java | 4 +-- .../chaos/actions/UnbalanceRegionsAction.java | 4 +-- .../chaos/monkies/PolicyBasedChaosMonkey.java | 6 ++-- .../hbase/chaos/policies/PeriodicPolicy.java | 4 +-- .../hadoop/hbase/chaos/util/ChaosMonkeyRunner.java | 2 +- .../hbase/mapreduce/IntegrationTestBulkLoad.java | 2 +- .../hadoop/hbase/mttr/IntegrationTestMTTR.java | 2 +- ...nTestTimeBoundedRequestsWithRegionReplicas.java | 2 +- hbase-mapreduce/pom.xml | 4 +++ .../hadoop/hbase/mapreduce/HFileOutputFormat2.java | 2 +- .../apache/hadoop/hbase/mapreduce/ImportTsv.java | 2 +- .../apache/hadoop/hbase/mapreduce/RowCounter.java | 2 +- .../apache/hadoop/hbase/PerformanceEvaluation.java | 2 +- hbase-metrics-api/pom.xml | 4 +-- .../hadoop/hbase/metrics/MetricRegistryInfo.java | 2 +- hbase-replication/pom.xml | 4 +-- .../hbase/replication/ReplicationFactory.java | 2 +- .../TableBasedReplicationQueuesClientImpl.java | 9 +++--- .../TableBasedReplicationQueuesImpl.java | 14 ++++----- .../src/main/resources/META-INF/NOTICE.vm | 12 ++++++++ hbase-rest/pom.xml | 4 +-- .../org/apache/hadoop/hbase/rest/RESTServer.java | 2 +- .../org/apache/hadoop/hbase/rest/RowResource.java | 2 +- .../apache/hadoop/hbase/rest/TableResource.java | 2 +- .../apache/hadoop/hbase/rest/model/CellModel.java | 6 ++-- .../apache/hadoop/hbase/rest/model/RowModel.java | 6 ++-- .../hadoop/hbase/rest/HBaseRESTTestingUtility.java | 2 +- .../hadoop/hbase/rest/model/TestCellModel.java | 6 ++-- .../hadoop/hbase/rest/model/TestRowModel.java | 6 ++-- hbase-rsgroup/pom.xml | 4 +-- .../hadoop/hbase/rsgroup/RSGroupAdminServer.java | 2 +- .../balancer/TestRSGroupBasedLoadBalancer.java | 2 +- hbase-server/pom.xml | 4 +-- .../hbase/tmpl/regionserver/RegionListTmpl.jamon | 2 +- .../coordination/ZkSplitLogWorkerCoordination.java | 6 ++-- .../hbase/favored/FavoredNodeAssignmentHelper.java | 2 +- .../FanOutOneBlockAsyncDFSOutputSaslHelper.java | 2 +- .../hadoop/hbase/io/hfile/HFilePrettyPrinter.java | 2 +- .../hbase/mapreduce/LoadIncrementalHFiles.java | 2 +- .../hadoop/hbase/master/MasterCoprocessorHost.java | 2 +- .../hbase/master/MetricsMasterWrapperImpl.java | 2 +- .../hbase/master/RegionPlacementMaintainer.java | 2 +- .../hadoop/hbase/master/TableNamespaceManager.java | 4 +-- .../hbase/master/balancer/BaseLoadBalancer.java | 10 ++----- .../hadoop/hbase/quotas/MasterQuotaManager.java | 2 +- .../hbase/quotas/SnapshotQuotaObserverChore.java | 2 +- .../apache/hadoop/hbase/regionserver/CellSet.java | 33 +++++++++++----------- .../hadoop/hbase/regionserver/HRegionServer.java | 8 +++--- .../MetricsRegionServerWrapperImpl.java | 2 +- .../hbase/regionserver/NonLazyKeyValueScanner.java | 2 +- .../NonReversedNonLazyKeyValueScanner.java | 2 +- .../hadoop/hbase/regionserver/RSRpcServices.java | 2 +- .../hbase/regionserver/RegionCoprocessorHost.java | 2 +- .../regionserver/RegionServerCoprocessorHost.java | 2 +- .../hbase/regionserver/ReversedKeyValueHeap.java | 5 ++-- .../hadoop/hbase/regionserver/SegmentScanner.java | 2 +- .../hbase/regionserver/wal/AbstractFSWAL.java | 4 +-- .../HBaseInterClusterReplicationEndpoint.java | 4 +-- .../replication/regionserver/ReplicationSink.java | 2 +- .../regionserver/ReplicationSource.java | 2 +- .../hbase/security/visibility/VisibilityUtils.java | 2 +- .../java/org/apache/hadoop/hbase/tool/Canary.java | 4 +-- .../apache/hadoop/hbase/util/CompressionTest.java | 2 +- .../hadoop/hbase/util/FSTableDescriptors.java | 4 +-- .../org/apache/hadoop/hbase/util/HBaseFsck.java | 4 +-- .../apache/hadoop/hbase/util/RegionSplitter.java | 4 +-- .../hadoop/hbase/util/hbck/OfflineMetaRepair.java | 2 +- .../hbase/wal/NettyAsyncFSWALConfigHelper.java | 2 +- .../resources/hbase-webapps/master/procedures.jsp | 2 +- .../hbase-webapps/master/processMaster.jsp | 2 +- .../resources/hbase-webapps/master/processRS.jsp | 2 +- .../main/resources/hbase-webapps/master/table.jsp | 26 ++++++++--------- .../hbase-webapps/master/tablesDetailed.jsp | 2 +- .../src/main/resources/hbase-webapps/master/zk.jsp | 4 +-- .../hbase-webapps/regionserver/processRS.jsp | 2 +- .../hbase-webapps/regionserver/region.jsp | 2 +- .../apache/hadoop/hbase/HBaseTestingUtility.java | 2 +- .../hadoop/hbase/client/TestFromClientSide.java | 2 +- .../TestSaslFanOutOneBlockAsyncDFSOutput.java | 2 +- .../master/balancer/TestBaseLoadBalancer.java | 4 +-- ...terProcedureSchedulerPerformanceEvaluation.java | 2 +- .../hbase/namespace/TestNamespaceAuditor.java | 2 +- .../hadoop/hbase/regionserver/TestHRegion.java | 2 +- .../hbase/regionserver/TestMultiColumnScanner.java | 2 +- .../TestRegionMergeTransactionOnCluster.java | 4 +-- .../regionserver/TestScannerHeartbeatMessages.java | 2 +- .../hbase/regionserver/TestSplitWalDataLoss.java | 2 +- .../regionserver/TestTimestampFilterSeekHint.java | 2 +- .../compactions/MockStoreFileGenerator.java | 2 +- .../hadoop/hbase/security/TestSecureIPC.java | 4 +-- .../org/apache/hadoop/hbase/security/TestUser.java | 2 +- .../hadoop/hbase/util/MultiThreadedReader.java | 6 ++-- .../hadoop/hbase/util/MultiThreadedUpdater.java | 6 ++-- .../hadoop/hbase/util/TestRegionSplitter.java | 2 +- hbase-shaded/pom.xml | 4 +-- hbase-spark-it/pom.xml | 4 +-- .../hbase/spark/IntegrationTestSparkBulkLoad.java | 2 +- hbase-thrift/pom.xml | 4 +-- .../hadoop/hbase/thrift/ThriftServerRunner.java | 2 +- pom.xml | 8 +++--- src/main/asciidoc/_chapters/configuration.adoc | 2 +- 150 files changed, 293 insertions(+), 277 deletions(-) diff --git a/dev-support/docker/Dockerfile b/dev-support/docker/Dockerfile index c654ded6ac5912cb74fdde599695ac9eee1f75ab..62c603097eb28ba7cf24063a9773f881ac070bad 100644 --- a/dev-support/docker/Dockerfile +++ b/dev-support/docker/Dockerfile @@ -87,7 +87,7 @@ RUN apt-get -q update && apt-get -q install --no-install-recommends -y \ # Fixing the Apache commons / Maven dependency problem under Ubuntu: # See http://wiki.apache.org/commons/VfsProblems -RUN cd /usr/share/maven/lib && ln -s ../../java/commons-lang.jar . +RUN cd /usr/share/maven/lib && ln -s ../../java/commons-lang3-3.6.jar . ###### # Install findbugs diff --git a/hbase-backup/pom.xml b/hbase-backup/pom.xml index 9b3aac66d4d0c59fae4cd70770e230addfa1e30e..de620ba3d5959266c83baa638ebf3df4a5ebd521 100644 --- a/hbase-backup/pom.xml +++ b/hbase-backup/pom.xml @@ -140,8 +140,8 @@ commons-io - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/BackupInfo.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/BackupInfo.java index 1765bf35684178a710f917755209ce0ebb75705d..432fd37be88da347fd7cce3aae4b5203e8ba1de1 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/BackupInfo.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/BackupInfo.java @@ -29,7 +29,7 @@ import java.util.Map; import java.util.Map.Entry; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.TableName; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/RestoreDriver.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/RestoreDriver.java index 82a1b5637262d4cc1391a7a43a5bf5fabd8562ab..903ded129a3114fb137c7fd161efc6b0b8b8cb90 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/RestoreDriver.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/RestoreDriver.java @@ -36,7 +36,7 @@ import java.util.List; import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.HelpFormatter; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.java index 99fb06c37be7763e04eccac3af6d4cd264fe190a..6cef0e31df7b29562765fb78e6fe3f45608f713b 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.java @@ -26,7 +26,7 @@ import java.util.List; import java.util.Map; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java index 650ba2ed9c1e39f642d5319608451788fe0cec45..1ef104dc251584b913fefde510ea0fe9fed9f27b 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupCommands.java @@ -40,7 +40,7 @@ import java.util.List; import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.Options; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; import org.apache.hadoop.fs.FileSystem; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java index 4dab046d5247b06ecde3c7fdd1496870a620bb84..8dc9718e2ee2cb684fdd0529f912fa8ba23c62ff 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java @@ -31,7 +31,7 @@ import java.util.Set; import java.util.TreeMap; import java.util.TreeSet; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java index 6d48c32f121c3c98c6013943e0b7aa7a7d923db7..406494874134b1a8b20eaa12ad369d5aec2b9e45 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java @@ -29,7 +29,7 @@ import java.util.Map; import java.util.Set; import java.util.TreeMap; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.fs.FileSystem; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/RestoreTablesClient.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/RestoreTablesClient.java index ea7a7b8b93b88d3f5a92221fc60e33b70042ba7b..82427e3a27961852aee5adb31f23d0e1ac32f247 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/RestoreTablesClient.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/RestoreTablesClient.java @@ -29,7 +29,7 @@ import java.util.Map; import java.util.Set; import java.util.TreeSet; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupMergeJob.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupMergeJob.java index 00c5b83950329fbe482ef3c3e377e4a57345c326..373f143bdac641528353de05a57cb7243c4cbcc5 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupMergeJob.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupMergeJob.java @@ -25,7 +25,7 @@ import java.util.HashSet; import java.util.List; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java index 1209e7c31b118f134ce70eacd246135a1876c451..ba31a7d45ba24af87eab858a40e2e0c14b4950c5 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java @@ -22,7 +22,7 @@ import static org.apache.hadoop.hbase.backup.util.BackupUtils.succeeded; import java.io.IOException; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/BackupSet.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/BackupSet.java index 0da6fc4ea13e9d9e39822bcd91fcdd32367d59a6..098efa1a21509aee1478813fba9c1bee7ee5eea8 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/BackupSet.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/BackupSet.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.backup.util; import java.util.List; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java index 48a553f5c753dff211303b36e3b14884e6f38c0f..3ca79f6763b57a0f24697a758c165e8db361c4e4 100644 --- a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java +++ b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java @@ -17,7 +17,7 @@ import static org.junit.Assert.assertTrue; import java.io.IOException; import java.util.List; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.TableName; @@ -342,4 +342,4 @@ public class TestFullRestore extends TestBackupBase { int ret = ToolRunner.run(conf1, new RestoreDriver(), args); assertTrue(ret != 0); } -} \ No newline at end of file +} 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 7011ed32a5645f5e9c238ce26eab5586db34e600..011ddf29ad34c4185b948e54e3aedd7ea2e891e2 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 @@ -26,7 +26,7 @@ import java.io.IOException; import java.util.ArrayList; import java.util.List; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-client/pom.xml b/hbase-client/pom.xml index 67c03f3472d48552b6b89ad1793db116529ff88e..73d0265b33276ddf05ee0f46c29400b7c03e2ac5 100644 --- a/hbase-client/pom.xml +++ b/hbase-client/pom.xml @@ -151,8 +151,8 @@ commons-io - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java index 252243422a24d77edb6f7bbe8cb4bbebc71f5091..5e2585a62ee192ee659a8007fc3f2cae7172ff4e 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java @@ -29,7 +29,7 @@ import java.util.LinkedList; import java.util.Queue; import java.util.concurrent.ExecutorService; -import org.apache.commons.lang.mutable.MutableBoolean; +import org.apache.commons.lang3.mutable.MutableBoolean; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/FastFailInterceptorContext.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/FastFailInterceptorContext.java index 3f4483637feeb742957a845f9fb28c4ecb33fdfc..c033828f392ae74f3c35ed9f3abcacbfcf01b43c 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/FastFailInterceptorContext.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/FastFailInterceptorContext.java @@ -17,7 +17,7 @@ */ package org.apache.hadoop.hbase.client; -import org.apache.commons.lang.mutable.MutableBoolean; +import org.apache.commons.lang3.mutable.MutableBoolean; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.classification.InterfaceAudience; @@ -129,4 +129,4 @@ class FastFailInterceptorContext extends RetryingCallerInterceptorContext { this.tries = tries; return this; } -} \ No newline at end of file +} diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java index 52ec9cdb982eaf42d8191098f2a46f8a8897463d..9993742844193e7ffaa1b50e69f98428bb741353 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java @@ -26,7 +26,7 @@ import java.util.Map.Entry; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; -import org.apache.commons.lang.mutable.MutableBoolean; +import org.apache.commons.lang3.mutable.MutableBoolean; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java index 47b68e11f9961eff0c3d92fe337516e7f66cfe6d..531d8c07ed123f1cddf23d9ebf004cbbd7c23d15 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKAsyncRegistry.java @@ -29,7 +29,7 @@ import static org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper.removeMetaD import java.io.IOException; import java.util.concurrent.CompletableFuture; -import org.apache.commons.lang.mutable.MutableInt; +import org.apache.commons.lang3.mutable.MutableInt; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.curator.framework.CuratorFramework; @@ -248,4 +248,4 @@ class ZKAsyncRegistry implements AsyncRegistry { public void close() { zk.close(); } -} \ No newline at end of file +} diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationSerDeHelper.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationSerDeHelper.java index 19c504247e6806ec2b1efadd6781ff109dda169c..b4de870aa6d5305089d51e81d2bd3197f0d82af8 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationSerDeHelper.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/ReplicationSerDeHelper.java @@ -18,7 +18,7 @@ */ package org.apache.hadoop.hbase.client.replication; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; import org.apache.commons.logging.Log; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/TableCFs.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/TableCFs.java index 854517e027041d4b0833eede960020767d7e427f..fc27deb4a238b85788aeae41d9a71c9c0e33c33f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/TableCFs.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/replication/TableCFs.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.client.replication; import java.util.Map; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java index 726a9ef1d319e56e518b46b31a3b3c324717418e..9ebbc3307287843d47562fbfb809a438808dafd0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java @@ -25,7 +25,7 @@ import org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup; import java.util.HashMap; import java.util.Map; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.util.Pair; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/SpaceQuotaSnapshot.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/SpaceQuotaSnapshot.java index 18fe76a659fffefef9ea8afdb8a7b91ee9574de2..f691d7a69331a0ddbec96aee9ee812709ee85097 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/SpaceQuotaSnapshot.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/SpaceQuotaSnapshot.java @@ -18,7 +18,7 @@ package org.apache.hadoop.hbase.quotas; import java.util.Objects; -import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java index 1de3652d65cfe7522de7f2b995f37a4159905527..de35fc54be21126e302484ac36ce538d7f019bb1 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java @@ -35,7 +35,7 @@ import java.util.Map; import javax.security.auth.login.AppConfigurationEntry; import javax.security.auth.login.AppConfigurationEntry.LoginModuleControlFlag; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java index 775365749e87fa52dd872542fd9fc8155464f605..0925974af237cf6587e8aeae6eacf761a91ed451 100644 --- a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java +++ b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java @@ -34,7 +34,7 @@ import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.apache.hadoop.hbase.CellComparator; import org.apache.hadoop.hbase.DoNotRetryIOException; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -461,7 +461,7 @@ public class TestClientNoCluster extends Configured implements Tool { @Override public MutateResponse mutate(RpcController controller, MutateRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override @@ -476,14 +476,14 @@ public class TestClientNoCluster extends Configured implements Tool { public BulkLoadHFileResponse bulkLoadHFile( RpcController controller, BulkLoadHFileRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public CoprocessorServiceResponse execService( RpcController controller, CoprocessorServiceRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override @@ -505,19 +505,19 @@ public class TestClientNoCluster extends Configured implements Tool { @Override public CoprocessorServiceResponse execRegionServerService(RpcController controller, CoprocessorServiceRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public PrepareBulkLoadResponse prepareBulkLoad(RpcController controller, PrepareBulkLoadRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public CleanupBulkLoadResponse cleanupBulkLoad(RpcController controller, CleanupBulkLoadRequest request) throws ServiceException { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } } diff --git a/hbase-client/src/test/java/org/apache/hadoop/hbase/ipc/TestCellBlockBuilder.java b/hbase-client/src/test/java/org/apache/hadoop/hbase/ipc/TestCellBlockBuilder.java index 9addaa532b6d7128aa3c18d6dbdb23886a318d03..164bc85e546a9db06e4dc9958604748a22dc46ce 100644 --- a/hbase-client/src/test/java/org/apache/hadoop/hbase/ipc/TestCellBlockBuilder.java +++ b/hbase-client/src/test/java/org/apache/hadoop/hbase/ipc/TestCellBlockBuilder.java @@ -23,7 +23,7 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.util.Arrays; -import org.apache.commons.lang.time.StopWatch; +import org.apache.commons.lang3.time.StopWatch; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.impl.Log4JLogger; diff --git a/hbase-common/pom.xml b/hbase-common/pom.xml index 84e120b71ee1d1ec67dd5ced4fff45e24865bbf7..12043b585c0c3c4c4e47e03320b681f6efdb260c 100644 --- a/hbase-common/pom.xml +++ b/hbase-common/pom.xml @@ -233,8 +233,8 @@ compile - commons-lang - commons-lang + org.apache.commons + commons-lang3 compile diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java index 54e0eb8c2352d1433fce661bca087723fae7fe9e..70fe85e4325686482f3f75dc07ac01d6accbf438 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java @@ -27,7 +27,7 @@ import java.util.List; import java.util.UUID; import java.util.regex.Pattern; -import org.apache.commons.lang.ArrayUtils; +import org.apache.commons.lang3.ArrayUtils; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.util.Bytes; @@ -1364,6 +1364,8 @@ public final class HConstants { public static final String DEFAULT_SNAPSHOT_RESTORE_FAILSAFE_NAME = "hbase-failsafe-{snapshot.name}-{restore.timestamp}"; + public static final String NOT_IMPLEMENTED = "Not implemented"; + private HConstants() { // Can't be instantiated with this ctor. } diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/encoding/EncodedDataBlock.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/encoding/EncodedDataBlock.java index 5ec91f795cc4e32779a86444df1f55c4695e8c0b..36be64e10a010bc1f851a815aac61948bd9e9b02 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/encoding/EncodedDataBlock.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/encoding/EncodedDataBlock.java @@ -25,7 +25,7 @@ import java.io.OutputStream; import java.nio.ByteBuffer; import java.util.Iterator; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.KeyValue; diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/PairOfSameType.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/PairOfSameType.java index 3d520a8e12748379cf8819c8ffbfbbf650a72916..387c670e239c1c63bfe2601fe615eae1b9a70b02 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/PairOfSameType.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/PairOfSameType.java @@ -21,7 +21,8 @@ package org.apache.hadoop.hbase.util; import java.util.Iterator; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; /** @@ -106,7 +107,7 @@ public class PairOfSameType implements Iterable { @Override public void remove() { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } }; } diff --git a/hbase-hadoop2-compat/pom.xml b/hbase-hadoop2-compat/pom.xml index 735b27244a32abc31669a42d6541cd4f0be4f4b6..a28fe7362d013b642ea85f9afec7a38284048ba0 100644 --- a/hbase-hadoop2-compat/pom.xml +++ b/hbase-hadoop2-compat/pom.xml @@ -181,8 +181,8 @@ limitations under the License. ${hadoop-two.version} - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/metrics/impl/HBaseMetrics2HadoopMetricsAdapter.java b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/metrics/impl/HBaseMetrics2HadoopMetricsAdapter.java index ec4a1a793aac0c6b3772b38fec0dfc0dd08bd085..3a24b94de572a58b48f6dd19da39958501e7b9ce 100644 --- a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/metrics/impl/HBaseMetrics2HadoopMetricsAdapter.java +++ b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/metrics/impl/HBaseMetrics2HadoopMetricsAdapter.java @@ -34,7 +34,7 @@ package org.apache.hadoop.hbase.metrics.impl; import java.util.Map; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.metrics.Counter; diff --git a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/metrics2/lib/MutableHistogram.java b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/metrics2/lib/MutableHistogram.java index 6a2f2039fc7a0bac6e06cf0439c133aafdfcb5d4..604377d3a2914bc3176a1e965c59ccb98dab3c4e 100644 --- a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/metrics2/lib/MutableHistogram.java +++ b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/metrics2/lib/MutableHistogram.java @@ -18,7 +18,7 @@ package org.apache.hadoop.metrics2.lib; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.metrics.Histogram; import org.apache.hadoop.hbase.metrics.Interns; diff --git a/hbase-it/pom.xml b/hbase-it/pom.xml index 2a9cf753fc2914db503d670fda6fab5d59320ffb..e0da4bdd8bd8a592fdf7ab471d0e2a54b3ac5fa0 100644 --- a/hbase-it/pom.xml +++ b/hbase-it/pom.xml @@ -267,8 +267,8 @@ commons-math - commons-lang - commons-lang + org.apache.commons + commons-lang3 org.apache.htrace diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java index 55c6e28b6a41b49bdd4fdb709a97ac371f8847a0..be25eaa367623aa683574dd444bc3abc39849780 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java @@ -286,13 +286,13 @@ public class DistributedHBaseCluster extends HBaseCluster { @Override public void waitUntilShutDown() { // Simply wait for a few seconds for now (after issuing serverManager.kill - throw new RuntimeException("Not implemented yet"); + throw new RuntimeException(HConstants.NOT_IMPLEMENTED); } @Override public void shutdown() throws IOException { // not sure we want this - throw new RuntimeException("Not implemented yet"); + throw new RuntimeException(HConstants.NOT_IMPLEMENTED); } @Override diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java index 0f48e4f187853afce9af91cc2dbcc9631182b2fd..dbbcc4462f0d5778ab2a2241829c0de847a5151a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java @@ -23,7 +23,7 @@ import java.io.IOException; import java.util.Locale; import java.util.Map; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestBase.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestBase.java index 46f049045be63bbcb8dce85a88b69fa474f1ed7f..2be1b2b2a00a2357e91836c47c50ae4ca1f9251e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestBase.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestBase.java @@ -24,7 +24,7 @@ import java.util.Properties; import java.util.Set; import org.apache.commons.cli.CommandLine; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java index e2804535e54f0f71a7616f8109175e1412bc1e9b..d1a760bdab51dfef8d6abce441144edc6a69a286 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java @@ -25,8 +25,8 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; -import org.apache.commons.lang.RandomStringUtils; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomStringUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -257,7 +257,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { return null; } ArrayList namespaceList = new ArrayList<>(namespaceMap.keySet()); - String randomKey = namespaceList.get(RandomUtils.nextInt(namespaceList.size())); + String randomKey = namespaceList.get(RandomUtils.nextInt(0, namespaceList.size())); NamespaceDescriptor randomNsd = namespaceMap.get(randomKey); // remove from namespaceMap namespaceMap.remove(randomKey); @@ -306,12 +306,12 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { private NamespaceDescriptor createNamespaceDesc() { String namespaceName = "itnamespace" + String.format("%010d", - RandomUtils.nextInt(Integer.MAX_VALUE)); + RandomUtils.nextInt()); NamespaceDescriptor nsd = NamespaceDescriptor.create(namespaceName).build(); nsd.setConfiguration( nsTestConfigKey, - String.format("%010d", RandomUtils.nextInt(Integer.MAX_VALUE))); + String.format("%010d", RandomUtils.nextInt())); return nsd; } } @@ -331,7 +331,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { NamespaceDescriptor modifiedNsd = NamespaceDescriptor.create(namespaceName).build(); String nsValueNew; do { - nsValueNew = String.format("%010d", RandomUtils.nextInt(Integer.MAX_VALUE)); + nsValueNew = String.format("%010d", RandomUtils.nextInt()); } while (selected.getConfigurationValue(nsTestConfigKey).equals(nsValueNew)); modifiedNsd.setConfiguration(nsTestConfigKey, nsValueNew); admin.modifyNamespace(modifiedNsd); @@ -397,7 +397,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { return null; } ArrayList tableList = new ArrayList<>(tableMap.keySet()); - TableName randomKey = tableList.get(RandomUtils.nextInt(tableList.size())); + TableName randomKey = tableList.get(RandomUtils.nextInt(0, tableList.size())); TableDescriptor randomTd = tableMap.remove(randomKey); return randomTd; } @@ -436,7 +436,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { } private TableDescriptor createTableDesc() { - String tableName = String.format("ittable-%010d", RandomUtils.nextInt(Integer.MAX_VALUE)); + String tableName = String.format("ittable-%010d", RandomUtils.nextInt()); String familyName = "cf-" + Math.abs(RandomUtils.nextInt()); return TableDescriptorBuilder.newBuilder(TableName.valueOf(tableName)) .addColumnFamily(ColumnFamilyDescriptorBuilder.of(familyName)) @@ -581,7 +581,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { LOG.info("No column families in table: " + td); return null; } - ColumnFamilyDescriptor randomCfd = families[RandomUtils.nextInt(families.length)]; + ColumnFamilyDescriptor randomCfd = families[RandomUtils.nextInt(0, families.length)]; return randomCfd; } } @@ -624,7 +624,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { } private ColumnFamilyDescriptor createFamilyDesc() { - String familyName = String.format("cf-%010d", RandomUtils.nextInt(Integer.MAX_VALUE)); + String familyName = String.format("cf-%010d", RandomUtils.nextInt()); return ColumnFamilyDescriptorBuilder.of(familyName); } } @@ -643,7 +643,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { } Admin admin = connection.getAdmin(); - int versions = RandomUtils.nextInt(10) + 3; + int versions = RandomUtils.nextInt(0, 10) + 3; try { TableName tableName = selected.getTableName(); LOG.info("Altering versions of column family: " + columnDesc + " to: " + versions + @@ -698,7 +698,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { TableName tableName = selected.getTableName(); // possible DataBlockEncoding ids int[] possibleIds = {0, 2, 3, 4, 6}; - short id = (short) possibleIds[RandomUtils.nextInt(possibleIds.length)]; + short id = (short) possibleIds[RandomUtils.nextInt(0, possibleIds.length)]; LOG.info("Altering encoding of column family: " + columnDesc + " to: " + id + " in table: " + tableName); @@ -789,13 +789,13 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { for (int i = 0; i < numRows; i++){ // nextInt(Integer.MAX_VALUE)) to return positive numbers only byte[] rowKey = Bytes.toBytes( - "row-" + String.format("%010d", RandomUtils.nextInt(Integer.MAX_VALUE))); + "row-" + String.format("%010d", RandomUtils.nextInt())); ColumnFamilyDescriptor cfd = selectFamily(selected); if (cfd == null){ return; } byte[] family = cfd.getName(); - byte[] qualifier = Bytes.toBytes("col-" + RandomUtils.nextInt(Integer.MAX_VALUE) % 10); + byte[] qualifier = Bytes.toBytes("col-" + RandomUtils.nextInt() % 10); byte[] value = Bytes.toBytes("val-" + RandomStringUtils.randomAlphanumeric(10)); Put put = new Put(rowKey); put.addColumn(family, qualifier, value); @@ -873,7 +873,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { break; case DELETE_TABLE: // reduce probability of deleting table to 20% - if (RandomUtils.nextInt(100) < 20) { + if (RandomUtils.nextInt(0, 100) < 20) { new DeleteTableAction().perform(); } break; @@ -882,7 +882,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { break; case DELETE_COLUMNFAMILY: // reduce probability of deleting column family to 20% - if (RandomUtils.nextInt(100) < 20) { + if (RandomUtils.nextInt(0, 100) < 20) { new DeleteColumnFamilyAction().perform(); } break; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithACL.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithACL.java index d1292790b8b027a475c245435660971b064b315b..3865209254a00928e78da30f47d33e7707e4097e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithACL.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithACL.java @@ -22,7 +22,7 @@ import java.util.Arrays; import java.util.List; import org.apache.commons.cli.CommandLine; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.io.hfile.HFile; import org.apache.hadoop.hbase.security.User; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/StripeCompactionsPerformanceEvaluation.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/StripeCompactionsPerformanceEvaluation.java index 073de77413d3ee373370d2c921eba2cc055e7cbb..150dec9a1b1b103c4632f72056ce55ba32c1896e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/StripeCompactionsPerformanceEvaluation.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/StripeCompactionsPerformanceEvaluation.java @@ -23,7 +23,7 @@ import java.util.Locale; import java.util.Set; import org.apache.commons.cli.CommandLine; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java index 5ec9cdbe4e2f55007840e06dcadc87dbc87b3669..2f01afeaba2f632a0d8abf5ea87266a4c064aee4 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java @@ -26,7 +26,7 @@ import java.util.List; import java.util.function.BiConsumer; import java.util.function.Consumer; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -208,7 +208,7 @@ public class Action { int victimRegionCount = (int)Math.ceil(fractionOfRegions * regions.size()); LOG.debug("Removing " + victimRegionCount + " regions from " + server.getServerName()); for (int i = 0; i < victimRegionCount; ++i) { - int victimIx = RandomUtils.nextInt(regions.size()); + int victimIx = RandomUtils.nextInt(0, regions.size()); String regionId = HRegionInfo.encodeRegionName(regions.remove(victimIx)); victimRegions.add(Bytes.toBytes(regionId)); } @@ -223,7 +223,7 @@ public class Action { if (context.isStopping()) { break; } - int targetIx = RandomUtils.nextInt(toServers.size()); + int targetIx = RandomUtils.nextInt(0, toServers.size()); admin.move(victimRegion, Bytes.toBytes(toServers.get(targetIx).getServerName())); } } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java index f3827473a3affd732aa7a526b4a75b5c4930b180..0ef8cfdf4d45f3915ff8b9b79f80ac08892c7a23 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.chaos.actions; import java.io.IOException; -import org.apache.commons.lang.RandomStringUtils; +import org.apache.commons.lang3.RandomStringUtils; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.TableName; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java index bbb86a128a8a85e85383e7d229f2b19284a5abb1..7e812a8f55355a7a5c1128f8a11ae44b71b09a9a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java @@ -18,7 +18,7 @@ package org.apache.hadoop.hbase.chaos.actions; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; @@ -47,7 +47,7 @@ public class CompactMobAction extends Action { public void perform() throws Exception { HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility(); Admin admin = util.getAdmin(); - boolean major = RandomUtils.nextInt(100) < majorRatio; + boolean major = RandomUtils.nextInt(0, 100) < majorRatio; // Don't try the modify if we're stopping if (context.isStopping()) { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java index 046415f9335bd5999740f682662fada14c840482..f3fe6ff7980e7f31daecd6d43f31fe228b13a923 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.chaos.actions; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.TableName; @@ -51,7 +51,7 @@ public class CompactRandomRegionOfTableAction extends Action { public void perform() throws Exception { HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility(); Admin admin = util.getAdmin(); - boolean major = RandomUtils.nextInt(100) < majorRatio; + boolean major = RandomUtils.nextInt(0, 100) < majorRatio; LOG.info("Performing action: Compact random region of table " + tableName + ", major=" + major); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java index 3eab335b82ddff9254df5f644bc6441269d38292..521591c467394c120e35708cc4c8562b906e8143 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java @@ -18,7 +18,7 @@ package org.apache.hadoop.hbase.chaos.actions; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; @@ -46,7 +46,7 @@ public class CompactTableAction extends Action { public void perform() throws Exception { HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility(); Admin admin = util.getAdmin(); - boolean major = RandomUtils.nextInt(100) < majorRatio; + boolean major = RandomUtils.nextInt(0, 100) < majorRatio; LOG.info("Performing action: Compact table " + tableName + ", major=" + major); try { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java index aa796abab0b1a86aebd2bf4fc2b0b5aa54434863..686e622523e0bd40cf98811328b35adc4abe8ed0 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.chaos.actions; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.TableName; @@ -54,7 +54,7 @@ public class MergeRandomAdjacentRegionsOfTableAction extends Action { return; } - int i = RandomUtils.nextInt(regions.size() - 1); + int i = RandomUtils.nextInt(0, regions.size() - 1); HRegionInfo a = regions.get(i++); HRegionInfo b = regions.get(i); LOG.debug("Merging " + a.getRegionNameAsString() + " and " + b.getRegionNameAsString()); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java index 146c63c61cc205622fb63ce667827a609190c7fa..c3793d02ea2e1350126dbc12dca87e1e84d10095 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java @@ -22,7 +22,7 @@ import java.util.Collection; import java.util.Collections; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.TableName; @@ -77,7 +77,7 @@ public class MoveRegionsOfTableAction extends Action { try { String destServerName = - servers[RandomUtils.nextInt(servers.length)].getServerName(); + servers[RandomUtils.nextInt(0, servers.length)].getServerName(); LOG.debug("Moving " + regionInfo.getRegionNameAsString() + " to " + destServerName); admin.move(regionInfo.getEncodedNameAsBytes(), Bytes.toBytes(destServerName)); } catch (Exception ex) { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java index 6eab85c15388dafab14161af66642d20df60ea89..2c9a872cc7e9a61f4b3e89f9af20df5fd65f448a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.chaos.actions; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HRegionLocation; import org.apache.hadoop.hbase.client.RegionLocator; @@ -41,6 +41,6 @@ public class RestartRsHoldingTableAction extends RestartActionBaseAction { LOG.info("Performing action: Restart random RS holding table " + this.locator.getName()); List locations = locator.getAllRegionLocations(); - restartRs(locations.get(RandomUtils.nextInt(locations.size())).getServerName(), sleepTime); + restartRs(locations.get(RandomUtils.nextInt(0, locations.size())).getServerName(), sleepTime); } } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java index ba251987ef8d051b2c9a62e35f87c2fc20bec6ff..800a44554349ab22d13c99274581a39a0a68aa64 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java @@ -24,7 +24,7 @@ import java.util.LinkedList; import java.util.List; import java.util.Queue; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.ServerName; @@ -104,7 +104,7 @@ public class RollingBatchRestartRsAction extends BatchRestartRsAction { break; } - sleep(RandomUtils.nextInt((int)sleepTime)); + sleep(RandomUtils.nextInt(0, (int)sleepTime)); } } @@ -149,4 +149,4 @@ public class RollingBatchRestartRsAction extends BatchRestartRsAction { action.perform(); } -} \ No newline at end of file +} diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java index 626953dfccfd9c5cb8d304a581535b93e4372165..7b6f2925bc6725444430c2fb3f280d1100d1aeca 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java @@ -24,7 +24,7 @@ import java.util.LinkedList; import java.util.List; import java.util.Set; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ClusterStatus; import org.apache.hadoop.hbase.ServerName; import org.junit.Assert; @@ -65,7 +65,7 @@ public class UnbalanceKillAndRebalanceAction extends Action { liveCount + deadCount < victimServers.size()); List targetServers = new ArrayList<>(liveCount); for (int i = 0; i < liveCount + deadCount; ++i) { - int victimIx = RandomUtils.nextInt(victimServers.size()); + int victimIx = RandomUtils.nextInt(0, victimServers.size()); targetServers.add(victimServers.remove(victimIx)); } unbalanceRegions(status, victimServers, targetServers, HOARD_FRC_OF_REGIONS); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java index bdffdb188227cc8c4e033aa1c7e59a5f1ee1f007..e5faf08967c9dad3403ba1e339fbf465eeb69d4f 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java @@ -22,7 +22,7 @@ import java.util.ArrayList; import java.util.LinkedList; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ClusterStatus; import org.apache.hadoop.hbase.ServerName; @@ -52,7 +52,7 @@ public class UnbalanceRegionsAction extends Action { int targetServerCount = (int)Math.ceil(fractionOfServers * victimServers.size()); List targetServers = new ArrayList<>(targetServerCount); for (int i = 0; i < targetServerCount; ++i) { - int victimIx = RandomUtils.nextInt(victimServers.size()); + int victimIx = RandomUtils.nextInt(0, victimServers.size()); targetServers.add(victimServers.remove(victimIx)); } unbalanceRegions(status, victimServers, targetServers, fractionOfRegions); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java index 951f8f8777f58bcebed9caa6cfea3f22a575882a..70452bb55689a394895adb27e3a82ea72f75b1db 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java @@ -22,7 +22,7 @@ import java.util.ArrayList; import java.util.Collection; import java.util.List; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.IntegrationTestingUtility; @@ -61,7 +61,7 @@ public class PolicyBasedChaosMonkey extends ChaosMonkey { /** Selects a random item from the given items */ public static T selectRandomItem(T[] items) { - return items[RandomUtils.nextInt(items.length)]; + return items[RandomUtils.nextInt(0, items.length)]; } /** Selects a random item from the given items with weights*/ @@ -71,7 +71,7 @@ public class PolicyBasedChaosMonkey extends ChaosMonkey { totalWeight += pair.getSecond(); } - int cutoff = RandomUtils.nextInt(totalWeight); + int cutoff = RandomUtils.nextInt(0, totalWeight); int cummulative = 0; T item = null; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java index b7b6109f4d909828323607a1107b827aabe971ec..3b6908daee50506bce2504fb63d383b2d2831551 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java @@ -18,7 +18,7 @@ package org.apache.hadoop.hbase.chaos.policies; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.util.Threads; /** A policy which does stuff every time interval. */ @@ -32,7 +32,7 @@ public abstract class PeriodicPolicy extends Policy { @Override public void run() { // Add some jitter. - int jitter = RandomUtils.nextInt((int) periodMs); + int jitter = RandomUtils.nextInt(0, (int) periodMs); LOG.info("Sleeping for " + jitter + " to add jitter"); Threads.sleep(jitter); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java index f14232188eac303303917dcc0df9bc7a733083f9..591108599e9e1a2f2a7119077f714cfb7990729a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java @@ -22,7 +22,7 @@ import java.util.Properties; import java.util.Set; import org.apache.commons.cli.CommandLine; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java index 52f1223e593d5c89a9b8453bc4d9d98c69083a76..64784fc63bc8ed9c8c2f508ce5f6d8ec7b633ae5 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java @@ -24,7 +24,7 @@ import org.apache.hadoop.hbase.shaded.com.google.common.base.Joiner; import org.apache.hadoop.hbase.shaded.com.google.common.collect.Sets; import org.apache.commons.cli.CommandLine; -import org.apache.commons.lang.RandomStringUtils; +import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mttr/IntegrationTestMTTR.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mttr/IntegrationTestMTTR.java index 272af96a9eae56af002511c49d2ca086e3c20a69..97a06f46be0a0dede23bc5da0506707b6ca0421d 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mttr/IntegrationTestMTTR.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mttr/IntegrationTestMTTR.java @@ -29,7 +29,7 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; -import org.apache.commons.lang.RandomStringUtils; +import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.commons.math.stat.descriptive.DescriptiveStatistics; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestTimeBoundedRequestsWithRegionReplicas.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestTimeBoundedRequestsWithRegionReplicas.java index 5bd2c87330e940d587b75cda9b28939f061d46db..73374238602f95f9222ba7c1c692676d6d1d11db 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestTimeBoundedRequestsWithRegionReplicas.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestTimeBoundedRequestsWithRegionReplicas.java @@ -26,7 +26,7 @@ import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-mapreduce/pom.xml b/hbase-mapreduce/pom.xml index f75c9f916c519038f2474329d876eb5a810a0967..18104c1dae8dd9a6269d3f8c13465c515d640b1a 100644 --- a/hbase-mapreduce/pom.xml +++ b/hbase-mapreduce/pom.xml @@ -191,6 +191,10 @@ mockito-all test + + org.apache.commons + commons-lang3 + diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java index 7fea25427280b989c26cee0a1be480c2af2a9140..ca6b1e9932e94cf49c70eb6cb949a5f17fc929ac 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java @@ -34,7 +34,7 @@ import java.util.UUID; import java.util.function.Function; import java.util.stream.Collectors; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java index b64271efbc9981190286600d5cd51684441a3ff7..44b856c69617bc670fcb54c0e8e001fe7a7bb6b4 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java @@ -26,7 +26,7 @@ import java.util.ArrayList; import java.util.HashSet; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/RowCounter.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/RowCounter.java index 2e0591e4c2ddf7cd1c53659b3bc4812ec946b818..6aedc56f3d63ba66dbec6e89c5f50efe4b970253 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/RowCounter.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/RowCounter.java @@ -24,7 +24,7 @@ import java.util.ArrayList; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java index 23a70a91300047ba15a49ed422c4934de06c4cfd..6b058b0ac920bd470c92368f7687e3375b4bc15d 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java @@ -43,7 +43,7 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-metrics-api/pom.xml b/hbase-metrics-api/pom.xml index 325e563c311bee1c7c82360ed1c66455491ed28d..9e01b543c7cf4613274f64d39edb3235fee0cacf 100644 --- a/hbase-metrics-api/pom.xml +++ b/hbase-metrics-api/pom.xml @@ -93,8 +93,8 @@ commons-logging - commons-lang - commons-lang + org.apache.commons + commons-lang3 org.apache.hbase.thirdparty diff --git a/hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricRegistryInfo.java b/hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricRegistryInfo.java index 88ba232928def88fe285194c036b96c47d1c3187..7da2c19299ee75b5fa599e5f416a5e9c5520cb8f 100644 --- a/hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricRegistryInfo.java +++ b/hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricRegistryInfo.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.metrics; -import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; import org.apache.hadoop.hbase.classification.InterfaceAudience; /** diff --git a/hbase-replication/pom.xml b/hbase-replication/pom.xml index 87664f8414c4b757a316851bf647c186b3f51393..8bfa4dfbe68afcb15ac1de283bd90143f5212e1f 100644 --- a/hbase-replication/pom.xml +++ b/hbase-replication/pom.xml @@ -143,8 +143,8 @@ commons-io - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationFactory.java b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationFactory.java index 8506cbb257d1c0daa913f7a591be1aa010117bdf..05757b9f9b547afc2084a47d38383221b5f48262 100644 --- a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationFactory.java +++ b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationFactory.java @@ -18,7 +18,7 @@ */ package org.apache.hadoop.hbase.replication; -import org.apache.commons.lang.reflect.ConstructorUtils; +import org.apache.commons.lang3.reflect.ConstructorUtils; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Abortable; diff --git a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesClientImpl.java b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesClientImpl.java index 35075473bdbb0a3fffb907830191b7d0ad811ce7..a16b368544cf31f4b4ed091da4d31fe35736f1cd 100644 --- a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesClientImpl.java +++ b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesClientImpl.java @@ -18,9 +18,10 @@ */ package org.apache.hadoop.hbase.replication; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Abortable; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; @@ -95,18 +96,18 @@ public class TableBasedReplicationQueuesClientImpl extends ReplicationTableBase @Override public int getHFileRefsNodeChangeVersion() throws KeeperException { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public List getAllPeersFromHFileRefsQueue() throws KeeperException { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public List getReplicableHFiles(String peerId) throws KeeperException { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } } diff --git a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.java b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.java index bf55e8cf61531eb41170385aae5d9088a0a5b435..e91f1ad906de75032a5d22df7ed912ff6b5013ee 100644 --- a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.java +++ b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.java @@ -18,13 +18,14 @@ */ package org.apache.hadoop.hbase.replication; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Abortable; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.client.Delete; @@ -45,11 +46,8 @@ import org.apache.zookeeper.KeeperException; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; -import java.util.HashMap; -import java.util.HashSet; import java.util.List; import java.util.Map; -import java.util.Set; import java.util.SortedSet; import java.util.TreeSet; @@ -298,26 +296,26 @@ public class TableBasedReplicationQueuesImpl extends ReplicationTableBase @Override public void addPeerToHFileRefs(String peerId) throws ReplicationException { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public void removePeerFromHFileRefs(String peerId) { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public void addHFileRefs(String peerId, List> pairs) throws ReplicationException { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public void removeHFileRefs(String peerId, List files) { // TODO - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } private String buildQueueRowKey(String queueId) { diff --git a/hbase-resource-bundle/src/main/resources/META-INF/NOTICE.vm b/hbase-resource-bundle/src/main/resources/META-INF/NOTICE.vm index 953b316ed40d1070b090a887cdc37bee3d9405b3..c0ff317e5d362910f775925b1cb2d835bb8189b6 100644 --- a/hbase-resource-bundle/src/main/resources/META-INF/NOTICE.vm +++ b/hbase-resource-bundle/src/main/resources/META-INF/NOTICE.vm @@ -199,6 +199,13 @@ JRuby's licence. ## jruby bundles jquery, but we already ref that above. #end +#macro(commons_lang3_notice) +-- +## commons-lang3 has following note in the NOTICE file +This product includes software from the Spring Framework, +under the Apache License 2.0 (see: StringUtils.containsWhitespace()) + +#end ## first bundled source #if(${bundled-logo}) #orca_logo_notice() @@ -255,6 +262,11 @@ JRuby's licence. #if(${dep.artifactId.equals("jruby-complete")}) #set($jruby=true) #end +#if(${dep.artifactId.equals("commons-lang3")}) +#if(${dep.groupId.equals("org.apache.commons")}) +#commons_lang3_notice() +#end +#end #if( ${dep.licenses.isEmpty()} ) ERROR: This product includes ${dep.name} which has no licenses! Revert the change if invalid or if intentional add license info to supplemental-models.xml diff --git a/hbase-rest/pom.xml b/hbase-rest/pom.xml index 639c0c244dabc9a9e62c7af5156c41537e94d506..1660594f9b434f99e67e9a0a2032a551bf1bfa0a 100644 --- a/hbase-rest/pom.xml +++ b/hbase-rest/pom.xml @@ -268,8 +268,8 @@ httpcore - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java index eb3fc26e7d12a98205c5be647e89c8cb248cd2a9..721e108a368a16a2dac2f15a1585778c8dcf8873 100644 --- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java +++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java @@ -32,7 +32,7 @@ import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; import org.apache.commons.cli.PosixParser; -import org.apache.commons.lang.ArrayUtils; +import org.apache.commons.lang3.ArrayUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RowResource.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RowResource.java index ceb8bb24ae80a2eb43ce9263520faccbee01d11e..d6a3e14efe8b616ad04fb5e3f307679aea195341 100644 --- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RowResource.java +++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RowResource.java @@ -36,7 +36,7 @@ import javax.ws.rs.core.Response; import javax.ws.rs.core.Response.ResponseBuilder; import javax.ws.rs.core.UriInfo; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/TableResource.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/TableResource.java index ddfa8bb60ee81563231c77cf3147915b2109ad49..91e19ab18fe7a2eb3c10f4efd32eda23b09ebfe6 100644 --- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/TableResource.java +++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/TableResource.java @@ -31,7 +31,7 @@ import javax.ws.rs.QueryParam; import javax.ws.rs.core.Context; import javax.ws.rs.core.UriInfo; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.TableName; diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/CellModel.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/CellModel.java index 0b98816e239005f6842ada149213b708c0cbfee4..07544a63a041ed18e04dcb55dba1e95f4bb1dc65 100644 --- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/CellModel.java +++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/CellModel.java @@ -28,9 +28,9 @@ import javax.xml.bind.annotation.XmlAttribute; import javax.xml.bind.annotation.XmlRootElement; import javax.xml.bind.annotation.XmlValue; -import org.apache.commons.lang.builder.EqualsBuilder; -import org.apache.commons.lang.builder.HashCodeBuilder; -import org.apache.commons.lang.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.EqualsBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.hadoop.hbase.util.ByteStringer; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.CellUtil; diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/RowModel.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/RowModel.java index 663c838345fe512c07b0c6e5f212a7d1e6e964d3..b14c40994b560f2bab6e220f83ac6f35140215ef 100644 --- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/RowModel.java +++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/RowModel.java @@ -30,9 +30,9 @@ import javax.xml.bind.annotation.XmlAttribute; import javax.xml.bind.annotation.XmlElement; import javax.xml.bind.annotation.XmlRootElement; -import org.apache.commons.lang.builder.EqualsBuilder; -import org.apache.commons.lang.builder.HashCodeBuilder; -import org.apache.commons.lang.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.EqualsBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.rest.ProtobufMessageHandler; import org.codehaus.jackson.annotate.JsonProperty; diff --git a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/HBaseRESTTestingUtility.java b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/HBaseRESTTestingUtility.java index c5cc1217f8f799e07f81bae57c8be770a0991cb9..95d9432eca3f891ddfb7c7fa2ca2fd046f7b0e8e 100644 --- a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/HBaseRESTTestingUtility.java +++ b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/HBaseRESTTestingUtility.java @@ -18,7 +18,7 @@ */ package org.apache.hadoop.hbase.rest; -import org.apache.commons.lang.ArrayUtils; +import org.apache.commons.lang3.ArrayUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestCellModel.java b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestCellModel.java index d9e45df944a2efed69217b40bfc262acce9617c5..96e1089641912a0acc7691dad9466bb0125c5d5c 100644 --- a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestCellModel.java +++ b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestCellModel.java @@ -19,9 +19,9 @@ package org.apache.hadoop.hbase.rest.model; -import org.apache.commons.lang.StringUtils; -import org.apache.commons.lang.builder.ToStringBuilder; -import org.apache.commons.lang.builder.ToStringStyle; +import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; import org.apache.hadoop.hbase.testclassification.RestTests; import org.apache.hadoop.hbase.testclassification.SmallTests; import org.apache.hadoop.hbase.util.Bytes; diff --git a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestRowModel.java b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestRowModel.java index 5c2b90c41f5878cdd1e62c3fa71b6da7fba3377e..7ba61b893de19e9fed80c9d0893581bf8f484463 100644 --- a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestRowModel.java +++ b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/model/TestRowModel.java @@ -23,9 +23,9 @@ import java.util.Iterator; import javax.xml.bind.JAXBContext; -import org.apache.commons.lang.StringUtils; -import org.apache.commons.lang.builder.ToStringBuilder; -import org.apache.commons.lang.builder.ToStringStyle; +import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; import org.apache.hadoop.hbase.testclassification.RestTests; import org.apache.hadoop.hbase.testclassification.SmallTests; import org.apache.hadoop.hbase.util.Bytes; diff --git a/hbase-rsgroup/pom.xml b/hbase-rsgroup/pom.xml index 91f6fc95f6ff0ced8594e63dc842b3a42a0628f6..0bb9060c11c91bb297c744c8a99b23f4ecd388d5 100644 --- a/hbase-rsgroup/pom.xml +++ b/hbase-rsgroup/pom.xml @@ -148,8 +148,8 @@ commons-io - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServer.java b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServer.java index b9c19227bbc29ffe284b3a088dfe1aa22b736b22..11c2403e5a4e4b6ed9c709b39f91b74d55b6ec51 100644 --- a/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServer.java +++ b/hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServer.java @@ -28,7 +28,7 @@ import java.util.List; import java.util.Map; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.HRegionInfo; diff --git a/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRSGroupBasedLoadBalancer.java b/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRSGroupBasedLoadBalancer.java index 488afdf0e810c4aa28024c5cf7553ea891bce7bf..fe62d16173894100d624175b31157e6df0e77077 100644 --- a/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRSGroupBasedLoadBalancer.java +++ b/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRSGroupBasedLoadBalancer.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.master.balancer; import org.apache.hadoop.hbase.shaded.com.google.common.collect.ArrayListMultimap; import org.apache.hadoop.hbase.shaded.com.google.common.collect.Lists; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/pom.xml b/hbase-server/pom.xml index e1ef88234f0797e107ce7ba0bc185fd531f217a6..0fbe622f78e66368f5f27fdc02f9e8bc653bd5cb 100644 --- a/hbase-server/pom.xml +++ b/hbase-server/pom.xml @@ -503,8 +503,8 @@ commons-io - commons-lang - commons-lang + org.apache.commons + commons-lang3 commons-logging diff --git a/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RegionListTmpl.jamon b/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RegionListTmpl.jamon index 7088f60a700cddcc5fb3780f3be9685d89e5dca0..285dbe64d1fa6fb16c9aba657120e67f49dfcd29 100644 --- a/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RegionListTmpl.jamon +++ b/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RegionListTmpl.jamon @@ -22,7 +22,7 @@ <%import> java.util.*; - org.apache.commons.lang.time.FastDateFormat; + org.apache.commons.lang3.time.FastDateFormat; org.apache.hadoop.hbase.regionserver.HRegionServer; org.apache.hadoop.hbase.util.Bytes; org.apache.hadoop.hbase.HRegionInfo; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZkSplitLogWorkerCoordination.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZkSplitLogWorkerCoordination.java index e4fffa1b857f13e0726766842998b43eabeebf22..354f58167c5f1641d1127ad264a80602e7969b92 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZkSplitLogWorkerCoordination.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZkSplitLogWorkerCoordination.java @@ -26,8 +26,8 @@ import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; -import org.apache.commons.lang.math.RandomUtils; -import org.apache.commons.lang.mutable.MutableInt; +import org.apache.commons.lang3.RandomUtils; +import org.apache.commons.lang3.mutable.MutableInt; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -269,7 +269,7 @@ public class ZkSplitLogWorkerCoordination extends ZooKeeperListener implements // after a successful submit, sleep a little bit to allow other RSs to grab the rest tasks try { - int sleepTime = RandomUtils.nextInt(500) + 500; + int sleepTime = RandomUtils.nextInt(0, 500) + 500; Thread.sleep(sleepTime); } catch (InterruptedException e) { LOG.warn("Interrupted while yielding for other region servers", e); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/favored/FavoredNodeAssignmentHelper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/favored/FavoredNodeAssignmentHelper.java index c00101061038b995ffa5b71f1f4bccf7be95dfc6..54c5ddb2fddeec99381c775532287cbea843415d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/favored/FavoredNodeAssignmentHelper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/favored/FavoredNodeAssignmentHelper.java @@ -31,7 +31,7 @@ import java.util.Map.Entry; import java.util.Random; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java index bc6ab3cc08e778309ab9cdd6b8c668db1291fdd1..f07ef7e364a26db82227e3c5e22f8927d8f1b5e6 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.java @@ -73,7 +73,7 @@ import javax.security.sasl.SaslClient; import javax.security.sasl.SaslException; import org.apache.commons.codec.binary.Base64; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java index 43b5c24a37968a0ce2a9b62d1adaa9c66c9b8ef8..f30ba5a034d310d90e8a42d088870c8704b65769 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java @@ -45,7 +45,7 @@ import org.apache.commons.cli.OptionGroup; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; import org.apache.commons.cli.PosixParser; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index 7b4a353533aa5c848603467af1689e3265e83e32..375db39801310de826c4653cf5c4d62cdf4251a9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -52,7 +52,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; -import org.apache.commons.lang.mutable.MutableInt; +import org.apache.commons.lang3.mutable.MutableInt; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterCoprocessorHost.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterCoprocessorHost.java index 004f91d5e6b0483ce803a1a9f608200a1dfe1bf5..6c43fc081c0562de46268fde02b8b4e8a442b224 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterCoprocessorHost.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterCoprocessorHost.java @@ -23,7 +23,7 @@ import java.io.IOException; import java.util.List; import java.util.Set; -import org.apache.commons.lang.ClassUtils; +import org.apache.commons.lang3.ClassUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java index 518c7b4a41e97394165d99caac7a04d391f787f1..eb5399d238a00af84dda72b1d2bf6163869888c2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java @@ -23,7 +23,7 @@ import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionPlacementMaintainer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionPlacementMaintainer.java index ffc3e5b51f00f830672b3ee86c1b3604568c58c4..2c8024ed3e7597a87f03b8670bc2eadd86bf5f11 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionPlacementMaintainer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionPlacementMaintainer.java @@ -36,7 +36,7 @@ import org.apache.commons.cli.GnuParser; import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableNamespaceManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableNamespaceManager.java index d69b0c0d7926373164cb6b56a818324f6927796c..31e6300767f73b627838c938f0e99c03deb388e4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableNamespaceManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableNamespaceManager.java @@ -22,7 +22,7 @@ import java.io.IOException; import java.io.InterruptedIOException; import java.util.NavigableSet; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -360,4 +360,4 @@ public class TableNamespaceManager { } return maxRegions; } -} \ No newline at end of file +} diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java index f7203b92b10c7db7dec87dd6410fd6b8bf97dfb8..162ba92d49bd727fc66e3d7dddbb18b44796d6f5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java @@ -20,11 +20,9 @@ package org.apache.hadoop.hbase.master.balancer; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; -import java.util.Collections; import java.util.Comparator; import java.util.Deque; import java.util.HashMap; -import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; @@ -36,12 +34,13 @@ import java.util.TreeMap; import java.util.function.Predicate; import java.util.stream.Collectors; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.ClusterStatus; import org.apache.hadoop.hbase.HBaseIOException; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HDFSBlocksDistribution; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.ServerLoad; @@ -53,15 +52,12 @@ import org.apache.hadoop.hbase.master.MasterServices; import org.apache.hadoop.hbase.master.RackManager; import org.apache.hadoop.hbase.master.RegionPlan; import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type; -import org.apache.hadoop.hbase.security.access.AccessControlLists; -import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.hbase.shaded.com.google.common.annotations.VisibleForTesting; import org.apache.hadoop.hbase.shaded.com.google.common.base.Joiner; import org.apache.hadoop.hbase.shaded.com.google.common.collect.ArrayListMultimap; import org.apache.hadoop.hbase.shaded.com.google.common.collect.Lists; import org.apache.hadoop.hbase.shaded.com.google.common.collect.Sets; -import org.apache.zookeeper.KeeperException; /** * The base class for load balancers. It provides the the functions used to by @@ -634,7 +630,7 @@ public abstract class BaseLoadBalancer implements LoadBalancer { public Action undoAction() { // TODO implement this. This action is not being used by the StochasticLB for now // in case it uses it, we should implement this function. - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } @Override public String toString() { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/MasterQuotaManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/MasterQuotaManager.java index 3453b7a89058da197801e39145d8e81aea55345a..7c54c733ceb99d25b2605ac371c63a914412eb7f 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/MasterQuotaManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/MasterQuotaManager.java @@ -27,7 +27,7 @@ import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.ConcurrentHashMap; -import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.DoNotRetryIOException; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/SnapshotQuotaObserverChore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/SnapshotQuotaObserverChore.java index f16db1ef426bd2c3b324c1b6d773326e5e220111..c04967b72c13595ebd800506c46aef8df40b0782 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/SnapshotQuotaObserverChore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/SnapshotQuotaObserverChore.java @@ -31,7 +31,7 @@ import java.util.concurrent.TimeUnit; import java.util.function.Predicate; import java.util.stream.Collectors; -import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellSet.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellSet.java index 6da57d35cf928fee16b1da96b0fa1c7f1163bb66..a3ab2e6d8471877ee59790589c322c27a6877319 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellSet.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellSet.java @@ -18,6 +18,7 @@ */ package org.apache.hadoop.hbase.regionserver; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.shaded.com.google.common.annotations.VisibleForTesting; import java.util.Collection; import java.util.Comparator; @@ -61,7 +62,7 @@ public class CellSet implements NavigableSet { } public Cell ceiling(Cell e) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Iterator descendingIterator() { @@ -69,11 +70,11 @@ public class CellSet implements NavigableSet { } public NavigableSet descendingSet() { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Cell floor(Cell e) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public SortedSet headSet(final Cell toElement) { @@ -86,7 +87,7 @@ public class CellSet implements NavigableSet { } public Cell higher(Cell e) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Iterator iterator() { @@ -94,24 +95,24 @@ public class CellSet implements NavigableSet { } public Cell lower(Cell e) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Cell pollFirst() { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Cell pollLast() { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public SortedSet subSet(Cell fromElement, Cell toElement) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public NavigableSet subSet(Cell fromElement, boolean fromInclusive, Cell toElement, boolean toInclusive) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public SortedSet tailSet(Cell fromElement) { @@ -123,7 +124,7 @@ public class CellSet implements NavigableSet { } public Comparator comparator() { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Cell first() { @@ -139,7 +140,7 @@ public class CellSet implements NavigableSet { } public boolean addAll(Collection c) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public void clear() { @@ -152,7 +153,7 @@ public class CellSet implements NavigableSet { } public boolean containsAll(Collection c) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public boolean isEmpty() { @@ -164,11 +165,11 @@ public class CellSet implements NavigableSet { } public boolean removeAll(Collection c) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public boolean retainAll(Collection c) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public Cell get(Cell kv) { @@ -180,10 +181,10 @@ public class CellSet implements NavigableSet { } public Object[] toArray() { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } public T[] toArray(T[] a) { - throw new UnsupportedOperationException("Not implemented"); + throw new UnsupportedOperationException(HConstants.NOT_IMPLEMENTED); } } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 96050a62e00aa87396162eb375b37f51d9039834..b6d9520e2dacce613cfe96bad389399d110a65fe 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -56,8 +56,8 @@ import javax.management.MalformedObjectNameException; import javax.management.ObjectName; import javax.servlet.http.HttpServlet; -import org.apache.commons.lang.SystemUtils; -import org.apache.commons.lang.math.RandomUtils; +import org.apache.commons.lang3.SystemUtils; +import org.apache.commons.lang3.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -1824,7 +1824,7 @@ public class HRegionServer extends HasThread implements if (((HRegion)r).shouldFlush(whyFlush)) { FlushRequester requester = server.getFlushRequester(); if (requester != null) { - long randomDelay = RandomUtils.nextInt(RANGE_OF_DELAY) + MIN_DELAY_TIME; + long randomDelay = RandomUtils.nextInt(0, RANGE_OF_DELAY) + MIN_DELAY_TIME; LOG.info(getName() + " requesting flush of " + r.getRegionInfo().getRegionNameAsString() + " because " + whyFlush.toString() + @@ -3510,7 +3510,7 @@ public class HRegionServer extends HasThread implements private boolean isHealthCheckerConfigured() { String healthScriptLocation = this.conf.get(HConstants.HEALTH_SCRIPT_LOC); - return org.apache.commons.lang.StringUtils.isNotBlank(healthScriptLocation); + return org.apache.commons.lang3.StringUtils.isNotBlank(healthScriptLocation); } /** diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperImpl.java index f43db93243d2e7c3efaa374beb59944062ff45e5..f2f6c79a80bfcdd4b76acbfc26cc8442c044a90e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperImpl.java @@ -23,7 +23,7 @@ import java.util.List; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.CompatibilitySingletonFactory; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.java index 8778f5d7058c5881e83981e8a8630c35f912c27e..c10aff963c59127eb7cbe8a463b6414f7f761e9c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.regionserver; import java.io.IOException; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Cell; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonReversedNonLazyKeyValueScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonReversedNonLazyKeyValueScanner.java index 1eb05f0fbe31031045dddc2e9b6b8ec7a704bcdd..1f8e897660e0c3e2ae71560a49fe759da533db71 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonReversedNonLazyKeyValueScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NonReversedNonLazyKeyValueScanner.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.regionserver; import java.io.IOException; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.Cell; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 707321d229e28380e249d7aeb600a15f97710941..4efa01cb0c0104879ad56384b68623cd3e69d0c9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -43,7 +43,7 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.LongAdder; -import org.apache.commons.lang.mutable.MutableObject; +import org.apache.commons.lang3.mutable.MutableObject; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.java index dfe22ba5453e4eb559c4ca8dc660b11df0adcf79..17ee48c75ee50bbed25799f2a2c8e97cb8516033 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.java @@ -31,7 +31,7 @@ import java.util.regex.Matcher; import org.apache.commons.collections.map.AbstractReferenceMap; import org.apache.commons.collections.map.ReferenceMap; -import org.apache.commons.lang.ClassUtils; +import org.apache.commons.lang3.ClassUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java index 9bcf2012376ea6c5abe389ae52760259d3697d9d..9e9e29cb3d42fbd718b7caba0720f0bc5e2f831f 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java @@ -22,7 +22,7 @@ import java.io.IOException; import java.util.Comparator; import java.util.List; -import org.apache.commons.lang.ClassUtils; +import org.apache.commons.lang3.ClassUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedKeyValueHeap.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedKeyValueHeap.java index 2035902341fc3c1468c70e835b01698eed5cc708..b0974dcc14da33c51765321d1857a01c6fa38850 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedKeyValueHeap.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedKeyValueHeap.java @@ -21,7 +21,8 @@ package org.apache.hadoop.hbase.regionserver; import java.io.IOException; import java.util.List; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellComparator; @@ -188,6 +189,6 @@ public class ReversedKeyValueHeap extends KeyValueHeap { @Override public boolean seekToLastRow() throws IOException { - throw new NotImplementedException("Not implemented"); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentScanner.java index 08ded8807e0922e29d9bc01447ee500781354ec7..ffdf295c1d1ca7b21df1f930100db9b552b007ca 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentScanner.java @@ -22,7 +22,7 @@ import java.io.IOException; import java.util.Iterator; import java.util.SortedSet; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellUtil; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java index a79d4c83b6dcee8a6b24a99ab9355ce33587fa5a..846c87d43a72527e312d65b96c2b96cefcdbc5bf 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java @@ -42,7 +42,7 @@ import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.locks.ReentrantLock; -import org.apache.commons.lang.mutable.MutableLong; +import org.apache.commons.lang3.mutable.MutableLong; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -366,7 +366,7 @@ public abstract class AbstractFSWAL implements WAL { } if (walFileSuffix.isEmpty()) { // in the case of the null suffix, we need to ensure the filename ends with a timestamp. - return org.apache.commons.lang.StringUtils + return org.apache.commons.lang3.StringUtils .isNumeric(fileNameString.substring(prefixPathStr.length())); } else if (!fileNameString.endsWith(walFileSuffix)) { return false; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java index 6c795378faa2d278f4513f326c4f1085ffd73d48..7a4f28f9f3f6040fcdf86f5fdb95758eeb47382c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java @@ -37,7 +37,7 @@ import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -446,4 +446,4 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi } } } -} \ No newline at end of file +} diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java index 620b28bc9eb9bffae9314ae2a5b647e3a2fbddbe..80ef6e398a5c4cfeffd6dcbc133169a6d90d1e0e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java @@ -30,7 +30,7 @@ import java.util.TreeMap; import java.util.UUID; import java.util.concurrent.atomic.AtomicLong; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java index f3a37ddc5d8d8ff8ee97838707089a5ca0987913..1a17a2ed95b7a75bf91255c62b79cd9516d283e5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java @@ -34,7 +34,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicLong; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/visibility/VisibilityUtils.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/visibility/VisibilityUtils.java index a2a99b352fab270ac77aca0aac15c3acb365f380..c6fc186e609650c3da6f4fef5ff1048ace671b05 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/visibility/VisibilityUtils.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/visibility/VisibilityUtils.java @@ -31,7 +31,7 @@ import java.util.Map; import java.util.Map.Entry; import java.util.Set; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java index 3051ab4235e2c92c35b90420c2bb0abf834c7cf3..56517a4835c92feac30f7df41d84388b94dae2ea 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java @@ -48,7 +48,7 @@ import java.util.concurrent.atomic.AtomicLong; import java.util.regex.Matcher; import java.util.regex.Pattern; -import org.apache.commons.lang.time.StopWatch; +import org.apache.commons.lang3.time.StopWatch; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -1572,4 +1572,4 @@ public final class Canary implements Tool { executor.shutdown(); System.exit(exitCode); } -} \ No newline at end of file +} diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/CompressionTest.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/CompressionTest.java index 7b745baf6846e8d6ad022af97ad7b28c175bc461..c6b11a98dfbcb64772362766301e7336fdd1fcad 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/CompressionTest.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/CompressionTest.java @@ -21,7 +21,7 @@ package org.apache.hadoop.hbase.util; import java.io.IOException; import java.util.Locale; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java index a73883b0b2dcdfa64107f2296e625fc6f8c2bc0a..a76dd5da28bfc77648a2fea6683eea166937c5da 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java @@ -29,7 +29,7 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; import edu.umd.cs.findbugs.annotations.Nullable; -import org.apache.commons.lang.NotImplementedException; +import org.apache.commons.lang3.NotImplementedException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; @@ -372,7 +372,7 @@ public class FSTableDescriptors implements TableDescriptors { } TableName tableName = htd.getTableName(); if (TableName.META_TABLE_NAME.equals(tableName)) { - throw new NotImplementedException(); + throw new NotImplementedException(HConstants.NOT_IMPLEMENTED); } if (HConstants.HBASE_NON_USER_TABLE_DIRS.contains(tableName.getNameAsString())) { throw new NotImplementedException( diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java index bc663e13267909177da968cb08c0fbc416635a47..556ee9e7310c99a4f383e3d571b62831e33784c7 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java @@ -69,8 +69,8 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import org.apache.commons.io.IOUtils; -import org.apache.commons.lang.RandomStringUtils; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.RandomStringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java index d487eb09e1e3fad99e996185cecde6197c872da4..b3c711a047a0b0099f641074dd669a09156776d4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java @@ -34,8 +34,8 @@ import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.OptionBuilder; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; -import org.apache.commons.lang.ArrayUtils; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.ArrayUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java index 8cda518ac86348ec4c35a22863f632a76e73cfa8..3c64d2e8730fe4b43c5cabfecdc8f456472abe1b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.util.hbck; import java.io.IOException; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java index 08796bea823fd071315907d01f75e0eeafbdafb5..34ef3f090401228a760ef91a32ee2ccf922efd60 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java @@ -25,7 +25,7 @@ import org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup; import java.util.HashMap; import java.util.Map; -import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.util.Pair; diff --git a/hbase-server/src/main/resources/hbase-webapps/master/procedures.jsp b/hbase-server/src/main/resources/hbase-webapps/master/procedures.jsp index a3701fffe6e0c00f3f9248935299f0f5da7e67e0..ce62fa1fa6221cfd406e39c187f229f5cd069db8 100644 --- a/hbase-server/src/main/resources/hbase-webapps/master/procedures.jsp +++ b/hbase-server/src/main/resources/hbase-webapps/master/procedures.jsp @@ -18,7 +18,7 @@ */ --%> <%@ page contentType="text/html;charset=UTF-8" - import="static org.apache.commons.lang.StringEscapeUtils.escapeXml" + import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml" import="java.util.Collections" import="java.util.Comparator" import="java.util.ArrayList" diff --git a/hbase-server/src/main/resources/hbase-webapps/master/processMaster.jsp b/hbase-server/src/main/resources/hbase-webapps/master/processMaster.jsp index d8e29ce577f31e04e2a07aaed0bcb44800448374..6e87e72ac7c7e8b5567148716b33f3121ec273aa 100644 --- a/hbase-server/src/main/resources/hbase-webapps/master/processMaster.jsp +++ b/hbase-server/src/main/resources/hbase-webapps/master/processMaster.jsp @@ -21,7 +21,7 @@ import="java.util.Date" import="java.util.List" import="org.apache.hadoop.hbase.HBaseConfiguration" - import="static org.apache.commons.lang.StringEscapeUtils.escapeXml" + import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml" import="javax.management.ObjectName" import="java.lang.management.ManagementFactory" import="java.lang.management.MemoryPoolMXBean" diff --git a/hbase-server/src/main/resources/hbase-webapps/master/processRS.jsp b/hbase-server/src/main/resources/hbase-webapps/master/processRS.jsp index 6abf8a1141c1f54f3d70679fcf2ec7eb4cb8f84d..cc18d5bb1f961eae37317e9ebac61ced9f7b45d7 100644 --- a/hbase-server/src/main/resources/hbase-webapps/master/processRS.jsp +++ b/hbase-server/src/main/resources/hbase-webapps/master/processRS.jsp @@ -21,7 +21,7 @@ import="java.util.Date" import="java.util.List" import="org.apache.hadoop.hbase.HBaseConfiguration" - import="static org.apache.commons.lang.StringEscapeUtils.escapeXml" + import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml" import="javax.management.ObjectName" import="java.lang.management.ManagementFactory" import="java.lang.management.MemoryPoolMXBean" diff --git a/hbase-server/src/main/resources/hbase-webapps/master/table.jsp b/hbase-server/src/main/resources/hbase-webapps/master/table.jsp index 6f3baf06b7dd31fedb7db8f376b47d23eefe2d1d..6c401a9d223c4876c1ed85c540f4c000ca9f156d 100644 --- a/hbase-server/src/main/resources/hbase-webapps/master/table.jsp +++ b/hbase-server/src/main/resources/hbase-webapps/master/table.jsp @@ -19,7 +19,7 @@ --%> <%@page import="org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier.RegionSpecifierType"%> <%@ page contentType="text/html;charset=UTF-8" - import="static org.apache.commons.lang.StringEscapeUtils.escapeXml" + import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml" import="org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString" import="java.net.URLEncoder" import="java.util.ArrayList" @@ -31,7 +31,7 @@ import="java.util.Collection" import="java.util.Collections" import="java.util.Comparator" - import="org.apache.commons.lang.StringEscapeUtils" + import="org.apache.commons.lang3.StringEscapeUtils" import="org.apache.hadoop.conf.Configuration" import="org.apache.hadoop.util.StringUtils" import="org.apache.hadoop.hbase.HRegionInfo" @@ -73,7 +73,7 @@ MetaTableLocator metaTableLocator = new MetaTableLocator(); String fqtn = request.getParameter("name"); - final String escaped_fqtn = StringEscapeUtils.escapeHtml(fqtn); + final String escaped_fqtn = StringEscapeUtils.escapeHtml4(fqtn); String sortKey = request.getParameter("sort"); String reverse = request.getParameter("reverse"); final boolean reverseOrder = (reverse==null||!reverse.equals("false")); @@ -122,7 +122,7 @@ <% if ( !readOnly && action != null ) { %> - HBase Master: <%= StringEscapeUtils.escapeHtml(master.getServerName().toString()) %> + HBase Master: <%= StringEscapeUtils.escapeHtml4(master.getServerName().toString()) %> <% } else { %> Table: <%= escaped_fqtn %> <% } %> @@ -276,7 +276,7 @@ if ( fqtn != null ) { %> <%= escapeXml(meta.getRegionNameAsString()) %> - <%= StringEscapeUtils.escapeHtml(metaLocation.getHostname().toString()) + ":" + master.getRegionServerInfoPort(metaLocation) %> + <%= StringEscapeUtils.escapeHtml4(metaLocation.getHostname().toString()) + ":" + master.getRegionServerInfoPort(metaLocation) %> <%= readReq%> <%= writeReq%> <%= fileSize%> @@ -317,7 +317,7 @@ if ( fqtn != null ) { } catch (Exception e) { // Nothing really to do here for(StackTraceElement element : e.getStackTrace()) { - %><%= StringEscapeUtils.escapeHtml(element.toString()) %><% + %><%= StringEscapeUtils.escapeHtml4(element.toString()) %><% } %> Unknown <% } @@ -398,7 +398,7 @@ if ( fqtn != null ) { for (HColumnDescriptor family: families) { %> - <%= StringEscapeUtils.escapeHtml(family.getNameAsString()) %> + <%= StringEscapeUtils.escapeHtml4(family.getNameAsString()) %> @@ -411,10 +411,10 @@ if ( fqtn != null ) { %> <% } %> @@ -708,7 +708,7 @@ ShowDetailName&Start/End Key"><%= StringEscapeUtils.escapeHtml(addr.getHostname().toString()) + ":" + master.getRegionServerInfoPort(addr) %> + <%= StringEscapeUtils.escapeHtml4(addr.getHostname().toString()) + ":" + master.getRegionServerInfoPort(addr) %> <% } else { @@ -761,7 +761,7 @@ if (withReplica) { String url = "//" + URLEncoder.encode(addr.getHostname()) + ":" + master.getRegionServerInfoPort(addr) + "/"; %> - + <% if (withReplica) { @@ -776,7 +776,7 @@ if (withReplica) { <% } } catch(Exception ex) { for(StackTraceElement element : ex.getStackTrace()) { - %><%= StringEscapeUtils.escapeHtml(element.toString()) %><% + %><%= StringEscapeUtils.escapeHtml4(element.toString()) %><% } } finally { admin.close(); @@ -894,7 +894,7 @@ Actions:
- <%= StringEscapeUtils.escapeHtml(familyKey.toString()) %> + <%= StringEscapeUtils.escapeHtml4(familyKey.toString()) %> - <%= StringEscapeUtils.escapeHtml(familyValues.get(familyKey).toString()) %> + <%= StringEscapeUtils.escapeHtml4(familyValues.get(familyKey).toString()) %>
<%= StringEscapeUtils.escapeHtml(addr.getHostname().toString()) + ":" + master.getRegionServerInfoPort(addr) %><%= StringEscapeUtils.escapeHtml4(addr.getHostname().toString()) + ":" + master.getRegionServerInfoPort(addr) %> <%= rdEntry.getValue()%>