fix ConcurrentModificationException in CachingClusteredClient.run() (a…

…pache#3278) * fix ConcurrentModificationException in CachingClusteredClient.run() * obtain new copy of PartitionHolder to avoid potential multi-threads read/write issue
gf53520 · Jul 29, 2016 · 1fa6819 · 1fa6819
1 parent 884017d
commit 1fa6819
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/common/src/main/java/io/druid/timeline/VersionedIntervalTimeline.java b/common/src/main/java/io/druid/timeline/VersionedIntervalTimeline.java
@@ -244,7 +244,7 @@ public Set<TimelineObjectHolder<VersionType, ObjectType>> findOvershadowed()
               new TimelineObjectHolder<VersionType, ObjectType>(
                   object.getTrueInterval(),
                   object.getVersion(),
-                  object.getPartitionHolder()
+                  new PartitionHolder<ObjectType>(object.getPartitionHolder())
               )
           );
         }
@@ -453,7 +453,7 @@ private List<TimelineObjectHolder<VersionType, ObjectType>> lookup(Interval inte
             new TimelineObjectHolder<VersionType, ObjectType>(
                 timelineInterval,
                 val.getVersion(),
-                val.getPartitionHolder()
+                new PartitionHolder<ObjectType>(val.getPartitionHolder())
             )
         );
       }