Skip to content

Commit 37180d4

Browse files
If usable disk space is equal but total is different
1 parent 41a47c2 commit 37180d4

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -551,9 +551,6 @@ tests:
551551
- class: org.elasticsearch.xpack.esql.qa.single_node.GenerativeIT
552552
method: test
553553
issue: https://github.com/elastic/elasticsearch/issues/129819
554-
- class: org.elasticsearch.index.engine.ThreadPoolMergeExecutorServiceDiskSpaceTests
555-
method: testAbortingOrRunningMergeTaskHoldsUpBudget
556-
issue: https://github.com/elastic/elasticsearch/issues/129823
557554
- class: org.elasticsearch.index.store.FsDirectoryFactoryTests
558555
method: testPreload
559556
issue: https://github.com/elastic/elasticsearch/issues/129852

server/src/test/java/org/elasticsearch/index/engine/ThreadPoolMergeExecutorServiceDiskSpaceTests.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import org.elasticsearch.threadpool.ThreadPool;
2929
import org.junit.After;
3030
import org.junit.AfterClass;
31+
import org.junit.Before;
3132
import org.junit.BeforeClass;
3233

3334
import java.io.IOException;
@@ -534,7 +535,7 @@ public void testAbortingOrRunningMergeTaskHoldsUpBudget() throws Exception {
534535
aFileStore.totalSpace = randomLongBetween(1_000L, 10_000L);
535536
bFileStore.totalSpace = randomLongBetween(1_000L, 10_000L);
536537
aFileStore.usableSpace = randomLongBetween(900L, aFileStore.totalSpace);
537-
bFileStore.usableSpace = randomLongBetween(900L, bFileStore.totalSpace);
538+
bFileStore.usableSpace = randomValueOtherThan(aFileStore.usableSpace, () -> randomLongBetween(900L, bFileStore.totalSpace));
538539
boolean aHasMoreSpace = aFileStore.usableSpace > bFileStore.usableSpace;
539540
try (
540541
ThreadPoolMergeExecutorService threadPoolMergeExecutorService = ThreadPoolMergeExecutorService
@@ -613,7 +614,7 @@ public void testBackloggedMergeTasksDoNotHoldUpBudget() throws Exception {
613614
aFileStore.totalSpace = randomLongBetween(1_000L, 10_000L);
614615
bFileStore.totalSpace = randomLongBetween(1_000L, 10_000L);
615616
aFileStore.usableSpace = randomLongBetween(900L, aFileStore.totalSpace);
616-
bFileStore.usableSpace = randomLongBetween(900L, bFileStore.totalSpace);
617+
bFileStore.usableSpace = randomValueOtherThan(aFileStore.usableSpace, () -> randomLongBetween(900L, bFileStore.totalSpace));
617618
boolean aHasMoreSpace = aFileStore.usableSpace > bFileStore.usableSpace;
618619
try (
619620
ThreadPoolMergeExecutorService threadPoolMergeExecutorService = ThreadPoolMergeExecutorService
@@ -900,7 +901,7 @@ public void testEnqueuedMergeTasksAreUnblockedWhenEstimatedMergeSizeChanges() th
900901
long diskSpaceLimitBytes = randomLongBetween(10L, 100L);
901902
aFileStore.usableSpace = diskSpaceLimitBytes + randomLongBetween(1L, 100L);
902903
aFileStore.totalSpace = aFileStore.usableSpace + randomLongBetween(1L, 10L);
903-
bFileStore.usableSpace = diskSpaceLimitBytes + randomLongBetween(1L, 100L);
904+
bFileStore.usableSpace = randomValueOtherThan(aFileStore.usableSpace, () -> diskSpaceLimitBytes + randomLongBetween(1L, 100L));
904905
bFileStore.totalSpace = bFileStore.usableSpace + randomLongBetween(1L, 10L);
905906
boolean aHasMoreSpace = aFileStore.usableSpace > bFileStore.usableSpace;
906907
Settings.Builder settingsBuilder = Settings.builder().put(settings);
@@ -1001,7 +1002,10 @@ public void testMergeTasksAreUnblockedWhenMoreDiskSpaceBecomesAvailable() throws
10011002
bFileStore.totalSpace = randomLongBetween(300L, 1_000L);
10021003
long grantedUsableSpaceBuffer = randomLongBetween(10L, 50L);
10031004
aFileStore.usableSpace = randomLongBetween(200L, aFileStore.totalSpace - grantedUsableSpaceBuffer);
1004-
bFileStore.usableSpace = randomLongBetween(200L, bFileStore.totalSpace - grantedUsableSpaceBuffer);
1005+
bFileStore.usableSpace = randomValueOtherThan(
1006+
aFileStore.usableSpace,
1007+
() -> randomLongBetween(200L, bFileStore.totalSpace - grantedUsableSpaceBuffer)
1008+
);
10051009
boolean aHasMoreSpace = aFileStore.usableSpace > bFileStore.usableSpace;
10061010
Settings.Builder settingsBuilder = Settings.builder().put(settings);
10071011
// change the watermark level, just for coverage and it's easier with the calculations

0 commit comments

Comments
 (0)