From 5eaaabce7f03b31146585a58689377ba4e6f7845 Mon Sep 17 00:00:00 2001
From: Fangjin Yang <fangjin@metamarketsgroup.com>
Date: Fri, 22 Mar 2013 17:05:39 -0700
Subject: [PATCH] fix for concurrent modifications in druid server

---
 .../main/java/com/metamx/druid/client/DruidServer.java    | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/client/src/main/java/com/metamx/druid/client/DruidServer.java b/client/src/main/java/com/metamx/druid/client/DruidServer.java
index a71d8a15ac7..ff565e04fce 100644
--- a/client/src/main/java/com/metamx/druid/client/DruidServer.java
+++ b/client/src/main/java/com/metamx/druid/client/DruidServer.java
@@ -24,8 +24,6 @@ import com.fasterxml.jackson.annotation.JsonProperty;
 import com.google.common.collect.ImmutableMap;
 import com.metamx.common.logger.Logger;
 
-
-
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -41,7 +39,7 @@ public class DruidServer implements Comparable
 
   private final String name;
   private final ConcurrentMap<String, DruidDataSource> dataSources;
-  private final Map<String, DataSegment> segments;
+  private final ConcurrentMap<String, DataSegment> segments;
 
   private final String host;
   private final long maxSize;
@@ -80,7 +78,7 @@ public class DruidServer implements Comparable
     this.tier = tier;
 
     this.dataSources = new ConcurrentHashMap<String, DruidDataSource>();
-    this.segments = new HashMap<String, DataSegment>();
+    this.segments = new ConcurrentHashMap<String, DataSegment>();
   }
 
   public String getName()
@@ -132,7 +130,7 @@ public class DruidServer implements Comparable
   @JsonProperty
   public Map<String, DataSegment> getSegments()
   {
-    return segments;
+    return ImmutableMap.copyOf(segments);
   }
 
   public DataSegment getSegment(String segmentName)