From 229559b46ac9eb77ad1dbad69b9d6d9683761a4c Mon Sep 17 00:00:00 2001 From: Charles Allen Date: Sat, 7 Jan 2017 12:34:47 -0800 Subject: [PATCH] Make TaskLockbox's ReentrantLock fair (#3828) --- .../src/main/java/io/druid/indexing/overlord/TaskLockbox.java | 2 +- 1 file changed, 1 insertion(+), 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 index 50eaa5ef3a7..0c496973873 100644 --- 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> 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);