Replace putIfAbsent with computeIfAbsent in DruidBalancer

metamx · Jun 27, 2017 · 11f2eaa · 11f2eaa
1 parent 574587b
commit 11f2eaa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorBalancer.java b/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorBalancer.java
@@ -91,7 +91,7 @@ public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
         params.getDruidCluster().getHistoricals().entrySet()) {
       String tier = entry.getKey();
 
-      currentlyMovingSegments.putIfAbsent(tier, new ConcurrentHashMap<>());
+      currentlyMovingSegments.computeIfAbsent(tier, t -> new ConcurrentHashMap<>());
 
       if (!currentlyMovingSegments.get(tier).isEmpty()) {
         reduceLifetimes(tier);