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);