From 585123f515c8f7aad1a51da1883b33fa04e6b4e2 Mon Sep 17 00:00:00 2001 From: Elliott Clark Date: Tue, 30 Jul 2013 11:20:37 -0700 Subject: [PATCH] HBASE-9087 --- .../main/java/org/apache/hadoop/hbase/regionserver/HStore.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java index 4624b9f..5fa086e 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java @@ -27,10 +27,11 @@ import java.util.Collections; import java.util.Iterator; import java.util.List; import java.util.NavigableSet; +import java.util.Set; import java.util.SortedSet; import java.util.concurrent.Callable; import java.util.concurrent.CompletionService; -import java.util.concurrent.CopyOnWriteArraySet; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.Future; @@ -145,8 +146,8 @@ public class HStore implements Store { final List filesCompacting = Lists.newArrayList(); // All access must be synchronized. - private final CopyOnWriteArraySet changedReaderObservers = - new CopyOnWriteArraySet(); + private final Set changedReaderObservers = + Collections.newSetFromMap(new ConcurrentHashMap()); private final int blocksize; private HFileDataBlockEncoder dataBlockEncoder; -- 1.7.10.2 (Apple Git-33)