From 63ae84759043c4ade9e5e5340bd16c76d34c911a Mon Sep 17 00:00:00 2001 From: zhangduo Date: Sun, 21 Dec 2014 19:39:09 +0800 Subject: [PATCH] HBASE-10201 Addendum fixes typo caused concurrency error --- .../src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java index d2ba69d..248b71a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java @@ -1684,7 +1684,7 @@ public class FSHLog implements WAL { oldestUnflushedStoreSequenceIdsOfRegion = new ConcurrentSkipListMap(Bytes.BYTES_COMPARATOR); ConcurrentMap alreadyPut = - oldestUnflushedStoreSequenceIds.put(encodedRegionName, + oldestUnflushedStoreSequenceIds.putIfAbsent(encodedRegionName, oldestUnflushedStoreSequenceIdsOfRegion); return alreadyPut == null ? oldestUnflushedStoreSequenceIdsOfRegion : alreadyPut; } -- 1.9.1