Make TaskLockbox's ReentrantLock fair (apache#3828)

Gamehu · Jan 7, 2017 · 229559b · 229559b
1 parent 3c01230
commit 229559b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/TaskLockbox.java b/indexing-service/src/main/java/io/druid/indexing/overlord/TaskLockbox.java
@@ -65,7 +65,7 @@ public class TaskLockbox
   // Datasource -> Interval -> Tasks + TaskLock
   private final Map<String, NavigableMap<Interval, TaskLockPosse>> running = Maps.newHashMap();
   private final TaskStorage taskStorage;
-  private final ReentrantLock giant = new ReentrantLock();
+  private final ReentrantLock giant = new ReentrantLock(true);
   private final Condition lockReleaseCondition = giant.newCondition();
 
   private static final EmittingLogger log = new EmittingLogger(TaskLockbox.class);