Fixed BLUR-176
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/4a6699d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/4a6699d3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/4a6699d3 Branch: refs/heads/0.2.0-newtypesystem Commit: 4a6699d324719c4cd50f360e1ebd48ee20201ac7 Parents: ac00999 Author: Aaron McCurry <[email protected]> Authored: Thu Aug 1 16:03:59 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Thu Aug 1 16:03:59 2013 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/blur/manager/status/QueryStatus.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4a6699d3/blur-core/src/main/java/org/apache/blur/manager/status/QueryStatus.java ---------------------------------------------------------------------- diff --git a/blur-core/src/main/java/org/apache/blur/manager/status/QueryStatus.java b/blur-core/src/main/java/org/apache/blur/manager/status/QueryStatus.java index 0c504ef..00df885 100644 --- a/blur-core/src/main/java/org/apache/blur/manager/status/QueryStatus.java +++ b/blur-core/src/main/java/org/apache/blur/manager/status/QueryStatus.java @@ -18,8 +18,8 @@ package org.apache.blur.manager.status; */ import java.lang.management.ManagementFactory; import java.lang.management.ThreadMXBean; -import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; @@ -50,7 +50,7 @@ public class QueryStatus implements Comparable<QueryStatus> { private final AtomicInteger _totalShards = new AtomicInteger(); private final AtomicInteger _completeShards = new AtomicInteger(); private final AtomicBoolean _running; - private final Map<String, CpuTime> _cpuTimes = new HashMap<String, CpuTime>(); + private final Map<String, CpuTime> _cpuTimes = new ConcurrentHashMap<String, CpuTime>(); public QueryStatus(long ttl, String table, BlurQuery blurQuery, AtomicBoolean running) { _ttl = ttl;
