Skip to content

Commit ab53108

Browse files
Checkstyle
1 parent 56df5f7 commit ab53108

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeExecutorService.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,9 @@
5555

5656
public class ThreadPoolMergeExecutorService implements Closeable {
5757
/** How frequently we check disk usage (default: 5 seconds). */
58-
public static final Setting<TimeValue> INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING = Setting.timeSetting(
58+
public static final Setting<TimeValue> INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING = Setting.positiveTimeSetting(
5959
"indices.merge.disk.check_interval",
6060
TimeValue.timeValueSeconds(5),
61-
TimeValue.MINUS_ONE,
6261
Setting.Property.NodeScope
6362
);
6463
public static final Setting<RelativeByteSizeValue> INDICES_MERGE_DISK_HIGH_WATERMARK_SETTING = new Setting<>(
@@ -453,8 +452,9 @@ ElementWithReleasableBudget take() throws InterruptedException {
453452
try {
454453
E peek;
455454
long peekBudget;
456-
while ((peek = enqueuedByBudget.peek()) == null || (peekBudget = budgetFunction.applyAsLong(peek)) > availableBudget)
455+
while ((peek = enqueuedByBudget.peek()) == null || (peekBudget = budgetFunction.applyAsLong(peek)) > availableBudget) {
457456
elementAvailable.await();
457+
}
458458
return new ElementWithReleasableBudget(enqueuedByBudget.poll(), peekBudget);
459459
} finally {
460460
lock.unlock();

0 commit comments

Comments
 (0)