HBASE-16190 IntegrationTestDDLMasterFailover failed with IllegalArgumentException: n must be positive (Romil Choksi and Heng Chen)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ee63706e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ee63706e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ee63706e Branch: refs/heads/branch-1.3 Commit: ee63706eed5fb3b72056c0228aae12104366076a Parents: 1ac755e Author: Enis Soztutar <e...@apache.org> Authored: Thu Jul 7 16:34:08 2016 -0700 Committer: Enis Soztutar <e...@apache.org> Committed: Thu Jul 7 16:36:02 2016 -0700 ---------------------------------------------------------------------- .../hbase/IntegrationTestDDLMasterFailover.java | 24 ++++++++++++-------- 1 file changed, 14 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/ee63706e/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java ---------------------------------------------------------------------- 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 47a3e4f..52a118a 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,13 +25,17 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; -import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; import org.apache.commons.lang.RandomStringUtils; import org.apache.commons.lang.math.RandomUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.hbase.client.*; +import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.Connection; +import org.apache.hadoop.hbase.client.ConnectionFactory; +import org.apache.hadoop.hbase.client.Put; +import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; import org.apache.hadoop.hbase.testclassification.IntegrationTests; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.HBaseFsck; @@ -246,12 +250,12 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { // NamespaceAction has implemented selectNamespace() shared by multiple namespace Actions protected NamespaceDescriptor selectNamespace( ConcurrentHashMap<String, NamespaceDescriptor> namespaceMap) { - // randomly select namespace from namespaceMap - if (namespaceMap.isEmpty()) { - return null; - } // synchronization to prevent removal from multiple threads synchronized (namespaceMap) { + // randomly select namespace from namespaceMap + if (namespaceMap.isEmpty()) { + return null; + } ArrayList<String> namespaceList = new ArrayList<String>(namespaceMap.keySet()); String randomKey = namespaceList.get(RandomUtils.nextInt(namespaceList.size())); NamespaceDescriptor randomNsd = namespaceMap.get(randomKey); @@ -386,12 +390,12 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { // TableAction has implemented selectTable() shared by multiple table Actions protected HTableDescriptor selectTable(ConcurrentHashMap<TableName, HTableDescriptor> tableMap) { - // randomly select table from tableMap - if (tableMap.isEmpty()){ - return null; - } // synchronization to prevent removal from multiple threads synchronized (tableMap){ + // randomly select table from tableMap + if (tableMap.isEmpty()) { + return null; + } ArrayList<TableName> tableList = new ArrayList<TableName>(tableMap.keySet()); TableName randomKey = tableList.get(RandomUtils.nextInt(tableList.size())); HTableDescriptor randomHtd = tableMap.get(randomKey);