From 3e076b2a8eb09ebc0fdf38f08c728592920ba67f Mon Sep 17 00:00:00 2001 From: Matt Warhaftig Date: Sat, 30 Apr 2016 13:27:11 -0400 Subject: [PATCH] HBASE-15563 Switch RegionGroupingProvider's region counter to AtomicLong. --- .../java/org/apache/hadoop/hbase/wal/BoundedGroupingStrategy.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/BoundedGroupingStrategy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/BoundedGroupingStrategy.java index 65c774e..f9be11c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/BoundedGroupingStrategy.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/BoundedGroupingStrategy.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.wal; import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.classification.InterfaceAudience; @@ -38,7 +38,7 @@ public class BoundedGroupingStrategy implements RegionGroupingStrategy{ private ConcurrentHashMap groupNameCache = new ConcurrentHashMap(); - private AtomicInteger counter = new AtomicInteger(0); + private AtomicLong counter = new AtomicLong(0); private String[] groupNames; @Override @@ -46,7 +46,7 @@ public class BoundedGroupingStrategy implements RegionGroupingStrategy{ String idStr = Bytes.toString(identifier); String groupName = groupNameCache.get(idStr); if (null == groupName) { - groupName = groupNames[counter.getAndIncrement() % groupNames.length]; + groupName = groupNames[(int) (counter.getAndIncrement() % groupNames.length)]; String extantName = groupNameCache.putIfAbsent(idStr, groupName); if (extantName != null) { return extantName; -- 2.6.4 (Apple Git-63)